栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

flink 消费kafka的数据出现异常排查

flink 消费kafka的数据出现异常排查

1、错误日志如下;

 

{
  "timestamp": "2022-01-27 17:07:55.680",
  "host": "gd12-k8s-noah-vrc-prod001-node-s0384",
  "message": "2022-01-27 17:07:49,041 INFO  org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-kafka_2_tendis_detail_gid-15, groupId=kafka_2_tendis_detail_gid] Node 4 was unable to process the fetch request with (sessionId=1381439767, epoch=1657025): FETCH_SESSION_ID_NOT_FOUND.",
  "path": "/apps/logs/log_receiver/ai-noah.vip.vip.com/tm-ord2tendis-all-flink-78988-gg7o5n-75f8448cc8-jbkcx/flink/dataeye/tm-ord2tendis-all.flink-78988.dataeye/ord2tendis-all.flink.bigdata.vip.com/task.log",
  "logLevel": "",
  "eventName": "",
  "logid": "8892444480957757",
  "threadName": ""
}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/722450.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号