你好,zhisheng,
我们并没有用到 flink-metrics-prometheus,只是任务执行的时候就会报出 找不到
org/apache/kafka/common/metrics/stats/Rate$1 这个类,不知道是否是flink自己调用到的
rockey...@163.com
发件人: zhisheng
发送时间: 2019-07-25 17:27
收件人: user-zh
主题: Re: flink kafka相关任务执行出错 导致 taskmanager 退出
hi,rockeycui
你是使用了 flink-metrics
谢谢,我们这边排查一下
rockey...@163.com
发件人: athlon...@gmail.com
发送时间: 2019-07-25 17:30
收件人: user-zh
主题: 回复: flink kafka相关任务执行出错 导致 taskmanager 退出
看看classpath里有没有kafka-clients
jar包,这个类是在这个里面的Rate类没有找到如果有那么看看你使用的kafka版本和kafka-clients是否匹配,我遇到类似的问题由于版本不同导致有的类找不到
看看classpath里有没有kafka-clients
jar包,这个类是在这个里面的Rate类没有找到如果有那么看看你使用的kafka版本和kafka-clients是否匹配,我遇到类似的问题由于版本不同导致有的类找不到
athlon...@gmail.com
发件人: rockey...@163.com
发送时间: 2019-07-25 17:26
收件人: user-zh
主题: flink kafka相关任务执行出错 导致 taskmanager 退出
你好,flink 运行过程中出现以下异常
hi,rockeycui
你是使用了 flink-metrics-prometheus 去 report metrics 数据吗?看到不少和 metrics 相关的字眼
rockey...@163.com 于2019年7月25日周四 下午5:12写道:
> 你好,flink 运行过程中出现以下异常,有何建议指导排除异常,
>
> 2019-07-23 10:52:01,420 INFO org.apache.kafka.common.utils.AppInfoParser
> - Kafka version : 0.9.0.1
>
你好,flink 运行过程中出现以下异常,有何建议指导排除异常,
2019-07-23 10:52:01,420 INFO org.apache.kafka.common.utils.AppInfoParser
- Kafka version : 0.9.0.1
2019-07-23 10:52:01,420 INFO org.apache.kafka.common.utils.AppInfoParser
- Kafka commitId : 23c69d62a0cabf06
2019-07-23
你好,flink 运行过程中出现以下异常,有何建议指导排除异常,
2019-07-23 10:52:01,420 INFO org.apache.kafka.common.utils.AppInfoParser
- Kafka version : 0.9.0.1
2019-07-23 10:52:01,420 INFO org.apache.kafka.common.utils.AppInfoParser
- Kafka commitId : 23c69d62a0cabf06
2019-07-23