@@ -15,6 +15,13 @@ unzip 1.10_release.zip
1515cd 1.10_release
1616```
1717
18+ 3.直接下载源码和编译好的插件包(推荐)
19+ ```
20+ wget https://github.com/DTStack/flinkx/releases/download/1.10.4/flinkx.7z
21+ 7za x flinkx.7z
22+ cd flinkx
23+ ```
24+
1825## 编译插件
1926
2027``` bash
@@ -87,9 +94,8 @@ mvn clean package -DskipTests
8794``` bash
8895bin/flinkx \
8996 -mode local \
90- -job $FLINKX_HOME /docs/example/stream_stream.json \
91- -pluginRoot $FLINKX_HOME /syncplugins \
92- -confProp " {\" flink.checkpoint.interval\" :60000}"
97+ -job docs/example/stream_stream.json \
98+ -pluginRoot syncplugins
9399```
94100
95101可以在flink的配置文件里配置端口:
@@ -104,8 +110,8 @@ rest.bind-port: 8888
104110``` bash
105111bin/flinkx \
106112 -mode local \
107- -job $FLINKX_HOME / docs/example/stream_stream.json \
108- -pluginRoot $FLINK_HOME / syncplugins \
113+ -job docs/example/stream_stream.json \
114+ -pluginRoot syncplugins
109115```
110116
111117任务运行后可以通过8888端口访问flink界面查看任务运行情况:
@@ -121,8 +127,8 @@ bin/flinkx \
121127``` bash
122128bin/flinkx \
123129 -mode standalone \
124- -job $FLINKX_HOME / docs/example/stream_stream.json \
125- -pluginRoot $FLINKX_HOME / syncplugins \
130+ -job docs/example/stream_stream.json \
131+ -pluginRoot syncplugins \
126132 -flinkconf $FLINK_HOME /conf \
127133 -confProp " {\" flink.checkpoint.interval\" :60000}"
128134```
@@ -145,7 +151,7 @@ $FLINK_HOME/bin/start-cluster.sh
145151``` bash
146152./bin/flinkx \
147153 -mode standalone \
148- -job $FLINKX_HOME / docs/example/stream_stream.json \
154+ -job docs/example/stream_stream.json \
149155 -flinkconf $FLINK_HOME /conf
150156```
151157
@@ -162,8 +168,8 @@ $FLINK_HOME/bin/start-cluster.sh
162168``` bash
163169bin/flinkx \
164170 -mode yarn \
165- -job $FLINKX_HOME / docs/example/stream_stream.json \
166- -pluginRoot $FLINKX_HOME / syncplugins \
171+ -job docs/example/stream_stream.json \
172+ -pluginRoot syncplugins \
167173 -flinkconf $FLINK_HOME /conf \
168174 -yarnconf $HADOOP_HOME /etc/hadoop \
169175 -confProp " {\" flink.checkpoint.interval\" :60000}"
@@ -188,7 +194,7 @@ $FLINK_HOME/bin/yarn-session.sh -n 1 -s 2 -jm 1024 -tm 1024
188194``` bash
189195bin/flinkx \
190196 -mode yarn \
191- -job $FLINKX_HOME / docs/example/stream_stream.json \
197+ -job docs/example/stream_stream.json \
192198 -flinkconf $FLINK_HOME /conf \
193199 -yarnconf $HADOOP_HOME /etc/hadoop
194200```
@@ -206,8 +212,8 @@ bin/flinkx \
206212``` bash
207213bin/flinkx \
208214 -mode yarnPer \
209- -job $FLINKX_HOME / docs/example/stream_stream.json \
210- -pluginRoot $FLINKX_HOME / syncplugins \
215+ -job docs/example/stream_stream.json \
216+ -pluginRoot syncplugins \
211217 -flinkconf $FLINK_HOME /conf \
212218 -yarnconf $HADOOP_HOME /etc/hadoop \
213219 -flinkLibJar $FLINK_HOME /lib \
@@ -221,8 +227,8 @@ bin/flinkx \
221227``` bash
222228bin/flinkx \
223229 -mode yarnPer \
224- -job $FLINKX_HOME / docs/example/stream_stream.json \
225- -pluginRoot $FLINKX_HOME / syncplugins \
230+ -job docs/example/stream_stream.json \
231+ -pluginRoot syncplugins \
226232 -yarnconf $HADOOP_HOME /etc/hadoop \
227233 -flinkLibJar $FLINK_HOME /lib \
228234 -pluginLoadMode classpath
0 commit comments