Shulou(Shulou.com)06/01 Report--

This article mainly explains "what is the common operation of Apache Flink". The content of the explanation is simple and clear, and it is easy to learn and understand. Please follow the editor's train of thought to study and learn "what is the common operation of Apache Flink".

Use Maven to compile and package your own code. The package is generally placed in the target subfolder of the project directory. Mvn clean packageflink task runs commands session mode runs flink run-- class com.zclh.data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.0-SNAPSHOT.jar specifies the user to run the task Job mode sudo-u hdfsbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-- class com.zclh.data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.0-SNAPSHOT.jarjob mode operation task bin/flink run-m yarn-cluster-yjm 1024-ytm 1024-class com.zclh.data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.0.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-class com.zclh .data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.1.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-- class com.zclh.data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.2.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-- class com.zclh.data.wordcount.WordCountKafkaInStdOut / data/cdh/test/flink-kafka-1.3.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024 -class com.atguigu.hotitems_analysis.KafkaProducerUtil / data/cdh/test/HotItemsAnalysis-1.0.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-- class com.atguigu.hotitems_analysis.HotItems / data/cdh/test/HotItemsAnalysis-2.0.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024 / data/cdh/test/HotItemsAnalysis-3.0.jar-- class com.atguigu.hotitems_analysis.HotItemsbin/flink run-- class com.atguigu.hotitems_analysis. HotItems / data/cdh/test/HotItemsAnalysis-3.0.jar launches the class java-cp / data/cdh/test/HotItemsAnalysis-4.0.jar com.atguigu.hotitems_analysis.KafkaProducerUtiljava-cp / data/cdh/test/HotItemsAnalysis-5.0.jar com.atguigu.hotitems_analysis.KafkaProducerUtilbin/flink run-- class com.atguigu.hotitems_analysis.HotItems / data/cdh/test/HotItemsAnalysis-4.0.jarbin/flink run-- class com.atguigu.hotitems_analysis.HotItems / specified in the jar package Data/cdh/test/HotItemsAnalysis-5.0.jarbin/flink run-m yarn-cluster-yjm 1024-ytm 1024-class com.atguigu.hotitems_analysis.HotItems / data/cdh/test/HotItemsAnalysis-5.0.jar Thank you for your reading The above is the content of "what is the common operation of Apache Flink". After the study of this article, I believe you have a deeper understanding of what the common operation of Apache Flink is, and the specific use needs to be verified in practice. Here is, the editor will push for you more related knowledge points of the article, welcome to follow!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.