我试图通过flink停止停止一项工作但是,CLI引发错误,不允许我停止作业。我可以取消它。这里的原因是什么?在org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:557) at org.apache.flink.client.cli.CliFrontend.runClusterAction(NoOpSecurityContext.java:30) at org
我正在检查带有kafka连接器的Flink simple能否在EXACTLY_ONCE模式下执行,我的方法是创建一个表,设置合理的检查点间隔,并在event_time字段上使用一个简单的滚函数,最后重新启动我的程序event_timestamp timestamp(3), watermark for event_timestamp as ....2:按以下配置启动我的Flink作业
StreamExecutionEnviron