退订发送到 user-zh-unsubscr...@flink.apache.org
| |
稚远
|
|
drewfrank...@163.com
行远自逊,笃行不怠
|
签名由网易邮箱大师定制
On 11/26/2021 17:44,蔡玉胜 wrote:
退订
退订
你好,我没有自己开发连接器,我用的是kafka
connector,influxdb只是作为一个metrics信息存储端,你是需要一个influxdb的连接器?我只是用到了metrics统计体系而已,只是自定义了Counter对象,和连接器没有什么关系
发自 网易邮箱大师
回复的原邮件
| 发件人 | 信华哺 |
| 日期 | 2021年11月26日 17:22 |
| 收件人 | user-zh@flink.apache.org |
| 抄送至 | |
| 主题 | 回复:Flink kafka自定义metrics在influxdb上解析失败 |
你好:
退订
| |
alwaysonlinedj
|
|
alwaysonlin...@163.com
|
签名由网易邮箱大师定制
你好:
我想问一下,你用的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信息里拿到的,我从构造中一层层传递进去。
但是发现一个奇怪的问题:当我