Как я могу справиться с бездельем в источнике кафки для водяных знаков с помощью таблицы или SQL api?
#apache-flink #flink-streaming #flink-sql Вопрос: Мы можем справиться с бездействием в api потока данных с помощью этого блока кода: WatermarkStrategy .<Tuple2<Long,String>>forBoundedOutOfOrderness(Duration.ofSeconds(20)) .withIdleness(Duration.ofMinutes(1)); Но возможно ли что-то подобное в flink table/SQL api?…