当我想用Flink sinkFunction写入或读取一些数据到MySQL时出现Flink数据库连接问题。但可能同时调用许多sinkFuction。我想知道是否有更好的方法来低成本解决这个问题？
因此，
您可以使用RichSinkFunction和覆盖方法open和close来创建和销毁与MySQL的连接。或者，将表 API 与表接收器一起使用是一种更好的方法（可以在此处找到更多信息：https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourceSinks.html#define-a-tablesink）