Flink jdbc接收器未在web ui中提交

Question

我的一个新开发的flink工作有问题。

当我在IntelliJ中运行它时，作业运行良好，并将记录提交到数据库。

下一步是将它上传到flinkwebui并在那里执行。

数据库连接已建立，插入内容似乎也已发送到oracle数据库，但数据似乎未提交。

我使用具有以下设置的数据流：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(10000);
...
DataStreamSink<POJO> pojoSink = filteredStream
.addSink(JdbcSink.sink(
sqlString,
JdbcStatementBuilder,
new JdbcConnectionOptions.JdbcConnectionOptionsBuilder()
.withUrl(url)
.withDriverName(driver)
.withUsername(user)
.withPassword(password)
.build());

我不知道为什么它能在IDE中的笔记本电脑上工作，但不能通过web ui在服务器上工作。服务器日志也没有任何错误，并显示了检查点。

也许有人建议我可以看看问题出在哪里。

干杯

Answer 1

这似乎是一个一次性错误。下一次作业将完美运行。