退订

回复：Flink kafka自定义metrics在influxdb上解析失败

你好： 我想问一下，你用的flink sql连接器是自己开发的么？ 我在网上只能找到一个datastream的influxdb连接器 在2021年7月23日 10:11，Jimmy Zhang 写道： 大家好，Flink版本1.13.1。 我在FlinkKafkaProducer的invork方法中，创建了一个counter，它采用sinkTableName+_receive_count作为最终的metric 表名，并且采用influxDB作为上报终端，其中，sinkTableName是从catalog信息里拿到的，我从构造中一层层传递进去。

求教：动态字段的处理

概3000条/秒，能勉强满足现有数据的峰值处理。但是数据一直在增长，可见的未来性能一定跟不上了。 请问有没有处理过类似问题的专家方便解答一下？ | | 信华哺 | | laoxin...@163.com | 签名由网易邮箱大师定制

mysql cdc配置问题求助

各位好： 我通过mysql cdc链接mysql(mariadb)一直不成功。网上也搜不到有效的解决方法。 用pyflink调试就一直运行也没数据也不报错。用flink sql就报java.net.ConnectException: Connection refused。 用slave可以远程连接mysql，也执行了 grant replication client, replication slave on *.* to 'slave'@'%' identified by 'slave';