- （1）使用yarn-per-job模式跑wordcount测试flink_on_yarn
- [root@hadoop101 flink-1.13.6-cdh6.3.2]# chmod 777 /opt/cloudera/parcels/FLINK/bin/flink
- [root@hadoop101 flink-1.13.6-cdh6.3.2]# sudo -u hdfs /opt/cloudera/parcels/FLINK/bin/flink run -t yarn-per-job /opt/cloudera/parcels/FLINK/lib/flink/examples/batch/WordCount.jar
- （2）验证Hive_FlinkSQL
- [root@hadoop101 flink-1.13.6-cdh6.3.2]# /opt/cloudera/parcels/FLINK/bin/flink-sql-client
作者 admin
张宴银，大数据开发工程师