From 93ce11e9900b61546c0e27531c3d30460a1464b9 Mon Sep 17 00:00:00 2001 From: zeekling Date: Wed, 3 Nov 2021 22:29:58 +0800 Subject: [PATCH] add flink commands --- README.md | 5 +++++ command/flink_command.md | 19 +++++++++++++++++++ 2 files changed, 24 insertions(+) create mode 100644 command/flink_command.md diff --git a/README.md b/README.md index 9259a54..904c9e1 100644 --- a/README.md +++ b/README.md @@ -7,3 +7,8 @@ - [Data Sink 介绍](https://www.zeekling.cn/articles/2020/05/04/1588666906660.html) - [自定义Data Sink](https://www.zeekling.cn/articles/2020/05/05/1588680092763.html) - [Flink 写入数据到 Kafka](https://www.zeekling.cn/articles/2020/05/15/1589474545288.html) + + +## flink 命令 + +- [flink命令详解](command/flink_command.md) diff --git a/command/flink_command.md b/command/flink_command.md new file mode 100644 index 0000000..f99fdcf --- /dev/null +++ b/command/flink_command.md @@ -0,0 +1,19 @@ + +## 简介 + +记录flink经常使用命令。 + +## 样例运行 +### batch样例 +#### 运行WordCount样例 + +```sh +cd /home/zeek/software/flink-1.12.5/examples/batch +/home/zeek/software/flink-1.12.5/bin/flink run WordCount.jar --input /tmp/word.txt --output /tmp/out.txt +``` +### sream样例 +#### 运行stream WordCount样例 +```sh +cd /home/zeek/software/flink-1.12.5/examples/streaming +/home/zeek/software/flink-1.12.5/bin/flink run WordCount.jar --input /tmp/word.txt --output /tmp/out.txt +```