Сбросить соединение с URL / портом - если данные не были получены за последние N минут - PullRequest
Новая
       19

Сбросить соединение с URL / портом - если данные не были получены за последние N минут

0 голосов
/ 03 мая 2019

У меня есть приложение flink, которое подключается к Url / Port, я вижу, что при стратегии перезапуска оно позволяет проверить, открыто ли соединение или нет.

Мой запрос ... Если соединение открыто, но за последние 'N' минут не было получено данных. Я хочу СБРОСИТЬ соединение

В настоящее время настройте соединение, используя базовые учебники по Flink.

    // set up the streaming execution environment
    val env = StreamExecutionEnvironment.getExecutionEnvironment

    val data_stream = env.socketTextStream(url, port, socket_stream_deliminator, socket_connection_retries)
                         .map(x => printInput(x))
                          .writeToSocket(url, port, new SimpleStringSchema())

    // execute program
    env.execute("Flink Streaming Scala API Skeleton")

Есть ли вызов функции или какая-то карта, которую нужно вызвать, чтобы проверить, отправило ли соединение данные за последние 'N' минут и если нет, то переподключиться.Как бы я поступил так

...