开发者社区 > 大数据与机器学习 > 大数据开发治理DataWorks > 正文

flink on k8s 报错读不出kafka数据来,on yarn没问题 有大佬知道这什么报错吗?

e50320a735655a767bbf9b4648c18c59.png flink on k8s 报错读不出kafka数据来,on yarn没问题 有大佬知道这什么报错吗?

展开
收起
滴滴滴~ 2023-03-21 15:29:34 367 0
2 条回答
写回答
取消 提交回答
  • 您好,很高兴为您解答。
    
    根据您提供的错误信息,我分析了可能的原因如下:
    
    1. **Kafka客户端版本不兼容**:请检查您在Kubernetes上使用的Kafka客户端版本是否与Kafka集群的版本兼容。如果版本不兼容,可能会导致客户端无法正确读取数据。
    
    2. **Kubernetes网络配置问题**:请检查Kubernetes集群的网络配置是否正确。确保Kafka客户端能够访问Kafka集群的端口,并且没有防火墙或其他网络设备阻止了访问。
    
    3. **Kafka集群配置问题**:请检查Kafka集群的配置是否正确。确保Kafka集群的配置与Kubernetes环境兼容,并且没有其他配置问题导致数据读取失败。
    
    4. **Kubernetes资源不足**:请检查Kubernetes集群的资源是否充足。如果Kubernetes集群的资源不足,可能会导致Kafka客户端无法正常运行,从而导致数据读取失败。
    
    5. **其他问题**:如果以上原因都无法解决问题,请检查其他可能导致数据读取失败的原因,例如Kafka集群的故障、网络连接问题等。
    
    希望这些信息对您有所帮助。如果您还有其他问题,请随时告诉我。
    
    2024-02-29 17:41:14
    赞同 展开评论 打赏
  • 网络问题。 此答案整理自钉群“Flink CDC 社区”

    2023-03-21 16:54:40
    赞同 展开评论 打赏

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

热门讨论

热门文章

相关电子书

更多
ACK 云原生弹性方案—云原生时代的加速器 立即下载
ACK集群类型选择最佳实践 立即下载
企业运维之云原生和Kubernetes 实战 立即下载

相关镜像