Flink jdbc 接收器未在网络中提交 ui

Question

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

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

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

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

我正在使用具有以下设置的 DataStream：

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 的笔记本电脑上运行，但不能通过网络 ui 在服务器上运行。服务器日志也没有任何错误并显示检查点。

也许有人有建议让我看看可能是什么问题。

干杯

Answer 1

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

Flink jdbc 接收器未在网络中提交 ui

Flink jdbc sink not commiting in web ui

apache-flink

flink-streaming