Блог

Главная - Вопросы по программированию - Сбой приемника jdbc, не фиксирующийся в веб-интерфейсе

Сбой приемника jdbc, не фиксирующийся в веб-интерфейсе

#apache-flink #flink-streaming

#апачи-флинк #flink-потоковая передача

Вопрос:

У меня проблема с одним из моих новых разработанных заданий flink.

Когда я запускаю его в IntelliJ, задание работает нормально и фиксирует записи в базе данных.

Следующим шагом было загрузить его в веб-интерфейс flink и выполнить его там.

Установлено соединение с базой данных, а также вставки, похоже, отправляются в базу данных 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, но не на сервере через веб-интерфейс.
В журналах сервера также нет ошибок и показаны контрольные точки.

Может быть, у кого-то есть предложение, где я мог бы посмотреть, в чем может быть проблема.

Ваше здоровье

Ответ №1:

Похоже, это была одноразовая ошибка. В следующий раз задание выполняется отлично.

Метки: ,