在select()函数或simplecondition/iterativecondition中对数据库执行flinkcep查询

mxg2im7a 于 2021-06-21 发布在 Flink

关注(0)|答案(1)|浏览(298)

我使用jdb连接器对postgresql数据库进行查询并处理结果。这个很好用！
但是，当我尝试在patternflatselectfunction中查询时，为了使查询结果成为收集新事件的条件，我得到了这个错误。
有人能帮我吗？我想好好了解一下发生了什么事。

jdbc apache-flink flink-cep database-connection

来源：https://stackoverflow.com/questions/54956593/flinkcep-query-to-database-within-select-function-or-simplecondition-iterative

1条答案

按热度按时间

qkf9rpyu1#

这个 PatternFlatSelectFunction 必须是 Serializable 发送给所有任务经理。
如果我没听错的话，你是在试图执行 DataSet 来自内部的程序 SelectFunction . 这是一个完全错误的方法，这是不可能的，因为这意味着你正在从taskmanagers内部产生新的工作。
您可以使用其他库从中查询数据库 PatternSelectFunction . 也要确保是的 Serializable .

赞(0）回复(0）举报 2021-06-21

我来回答

在select()函数或simplecondition/iterativecondition中对数据库执行flinkcep查询

1条答案

相关问题

热门标签

最新问答