如何使用 Table 或 SQL api 处理水印的 kafka 源中的空闲？
How Can I deal with Idleness in kafka source for watermarks using Table or SQL api?
我们可以通过以下代码块处理数据流 api 中的空闲：
WatermarkStrategy
.<Tuple2<Long,String>>forBoundedOutOfOrderness(Duration.ofSeconds(20))
.withIdleness(Duration.ofMinutes(1));
但是在 flink table/SQL api 中有类似的东西吗？
您可以设置table.exec.source.idle-timeout。有关详细信息，请参阅 https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/config/#table-exec-source-idle-timeout。
我们可以通过以下代码块处理数据流 api 中的空闲：
WatermarkStrategy
.<Tuple2<Long,String>>forBoundedOutOfOrderness(Duration.ofSeconds(20))
.withIdleness(Duration.ofMinutes(1));
但是在 flink table/SQL api 中有类似的东西吗？
您可以设置table.exec.source.idle-timeout。有关详细信息，请参阅 https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/config/#table-exec-source-idle-timeout。