Блог

Используя JDB connector, я выполняю запросы к базе данных PostgreSQL и обрабатываю результаты. Это отлично работает!

НО, когда я пытаюсь выполнить запрос в patternflatselectфункции, чтобы результаты запроса были условием, по которому я собираю новые события, я получаю эту ошибку.

Кто-нибудь может мне помочь? Я хотел бы получить хорошее представление о том, что происходит.

PatternFlatSelectFunction Должен быть Serializable , поскольку он отправляется всем TaskManagers.

Если я вас правильно понял, вы пытаетесь выполнить DataSet программу изнутри SelectFunction . Это совершенно неправильный подход, и это невозможно, поскольку это означало бы, что вы создаете новые задания из TaskManagers.

Вы можете использовать другие библиотеки для запроса вашей базы данных изнутри PatternSelectFunction . Также убедитесь, что это так Serializable .