大数据

阶段四flink无法消费kafka中的数据，可以通过分解任务找出异常点

发布于 2021-04-23 17:04:19

【多选题】
A 首先查看日志，定位错误大概范围，是代码错误还是配置错误
B flume是否正确配置监听端口，通过sink中logger日志方式打印查看，确认是否source问题
C 修改flume中sink为KafkaSink，单独启动kakfa消费者，查看Flume数据是否能够发送至kafka
D 如果是代码错误则查看日志错误行数和异常原因，找出错误的代码修改

关注者

0

被浏览

110

111 2023-04-23

这家伙很懒，什么也没写！

此回答被采纳为最佳答案，开通VIP会员可查看

1 个回答

撰写答案

请登录后再发布答案，点击登录

关于作者

jim19970316

这家伙很懒，什么也没写！

提问

回答

1168

被采纳

1160

关注TA

发私信

相关问题

1

适用于高速运动的凸轮机构从动件运动规律为余弦加速度运动

2

单扇屏蔽门无法打开，站台安全员首先需要考虑操作（）设备进行开门。

3

阶段一环境配置容易写错单词，导致启动失败，或者通讯异常。

4

单扇屏蔽门无法打开，在LCB无法开启的情况，站台安全需要使用（）钥匙开启故障屏蔽门。

5

阶段23：运行速度慢甚至报错

6

单扇屏蔽门无法打开，车站在故障门处需要张贴( )告示来提醒乘客。

7

图表无法显示

8

FAS主机烟感报警时应向（）上报

9

根据阶段五可视化图表写分析报告

10

SparkJob运行慢的原因和解决（调优也可以以此为答案）

发布
问题

手机
浏览

扫码手机浏览

在线
客服