当我想用flink写或读一些数据时，flink数据库连接出现问题 sinkFunction 对于mysql来说，每次操作的数据量都很小。但可能有很多 sinkFuction 同时调用。我想知道是否有更好的方法以低成本解决这个问题？
sinkFunction
sinkFuction
tuwxkamq1#
所以你可以用 RichSinkFunction 和重写方法 open 以及 close 创建和销毁到mysql的连接。或者将表api与表接收器一起使用是更好的方法（您可以在此处找到更多信息：https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourcesinks.html#define-a表墨水）
RichSinkFunction
open
close
1条答案
按热度按时间tuwxkamq1#
所以你可以用
RichSinkFunction和重写方法open以及close创建和销毁到mysql的连接。或者将表api与表接收器一起使用是更好的方法（您可以在此处找到更多信息：https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourcesinks.html#define-a表墨水）