select()函数或SimpleCondition/IterativeCondition中的数据库flinkCEP查询

Question

使用JDB连接器，我对PostgreSQL数据库进行查询并处理结果。这很好用！

，为了使查询结果成为收集新事件的条件，我得到了这个错误。

有谁可以帮我？我想对发生的事情有一个很好的了解。

Answer 1

PatternFlatSelectFunction必须是Serializable，因为它被发送到所有TaskManagers。

如果我正确地理解了您的意思，那么您正在尝试从DataSet内部执行SelectFunction程序。这是一种完全错误的方法，这是不可能的，因为这意味着您正在从TaskManagers内部产生新的工作。

您可以使用其他库从PatternSelectFunction中查询您的DB。还要确保它是Serializable。