: 1601475710619有趣的是,当我在IntelliJ上本地运行相同的应用程序,并且在相同的主题上有空闲的kafka分区时,我也会从水标中得到上面的日志,水印在0和最近接收元素的ts之间振荡,因为maxLag = 0。然而,对我来说非常出乎意料的是,来自process函数的日志显示水印还在前进:
In process function, got eve
我想从SQL客户端试用Flink SQL中的Match_Recognize操作符。at org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:147)
at org.apache.flink.table.client.SqlClient.startby: org.apache.flink.table.client.gateway.SqlExecutionException: C