CDH集成flink服务步骤说明，并且运行报错：Could not retrieve the execution result

骑猪看日落 2022-11-06 11:59 331阅读 0赞

CDH集成flink服务：https://blog.csdn.net/ygdlx521/article/details/106527724/

CDH集成flink服务后，运行测试案例：

  1. sudo -u hdfs flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 1024 /opt/cloudera/parcels/FLINK/lib/flink/examples/streaming/WordCount.jar --input hdfs://10.30.202.21:8020/tmp/word.txt --output hdfs://10.30.202.21:8020/tmp/result4

报错:

Could not retrieve the execution result. (JobID: 709502c433de4c469cbee6a3664161f0)

Failed to submit JobGraph.

[Internal server error.,

Could not set up JobManager

等等……

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMTAzMDE_size_16_color_FFFFFF_t_70

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMTAzMDE_size_16_color_FFFFFF_t_70 1

原因：结点不对。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMTAzMDE_size_16_color_FFFFFF_t_70 2

命令改为:

  1. sudo -u hdfs flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 1024 /opt/cloudera/parcels/FLINK/lib/flink/examples/streaming/WordCount.jar --input hdfs://10.30.202.21:8085/tmp/word.txt --output hdfs://10.30.202.21:8085/tmp/result

运行结果：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMTAzMDE_size_16_color_FFFFFF_t_70 3

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMTAzMDE_size_16_color_FFFFFF_t_70 4

发表评论

表情：
评论列表 （有 0 条评论，331人围观）

还没有评论，来说两句吧...

相关阅读