CODEWITHSUNDEEP
apache-flinkflink-streamingflink-sql
Mehul
Mehul

Reputation: 25

How Can I deal with Idleness in kafka source for watermarks using Table or SQL api?

We can handle the idleness in datastream api via this code block:

WatermarkStrategy
        .<Tuple2<Long,String>>forBoundedOutOfOrderness(Duration.ofSeconds(20))
        .withIdleness(Duration.ofMinutes(1));

But is something similar possible in flink table/SQL api?

Upvotes: 0

Views: 978

Answers (1)

David Anderson
David Anderson

Reputation: 43439

You can set table.exec.source.idle-timeout. See https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/config/#table-exec-source-idle-timeout for more info.

Upvotes: 2

Related Questions