Запрос flinkCEP к базе данных в функции select () или SimpleCondition / IterativeCondition

Question

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

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

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

Answer 1

Значение PatternFlatSelectFunction должно быть Serializable, поскольку оно отправляется всем менеджерам задач.

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

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