@@ -200,7 +200,7 @@ NOTE:将flinkx-dist目录拷贝到$FLINK_HOME/lib下,并修改$FLINK_HOME/conf
200200bin/flinkx \
201201 -mode standalone \
202202 -jobType sync \
203- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
203+ -job flinkx-examples /json/stream/stream.json \
204204 -flinkxDistDir flinkx-dist \
205205 -flinkConfDir $FLINK_HOME /conf \
206206 -confProp " {\" flink.checkpoint.interval\" :60000}"
@@ -226,7 +226,7 @@ $FLINK_HOME/bin/start-cluster.sh
226226 -mode standalone \
227227 -jobType sync \
228228 -flinkxDistDir flinkx-dist \
229- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
229+ -job flinkx-examples /json/stream/stream.json \
230230 -flinkConfDir $FLINK_HOME /conf
231231```
232232
@@ -245,7 +245,7 @@ NOTE:可以先在现在flinkx-clients模块YarnSessionClientUtil类中启动一
245245bin/flinkx \
246246 -mode yarn-session \
247247 -jobType sync \
248- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
248+ -job flinkx-examples /json/stream/stream.json \
249249 -flinkxDistDir flinkx-dist \
250250 -flinkConfDir $FLINK_HOME /conf \
251251 -hadoopConfDir $HADOOP_HOME /etc/hadoop \
@@ -272,7 +272,7 @@ $FLINK_HOME/bin/yarn-session.sh -n 1 -s 1 -jm 1024 -tm 1024
272272bin/flinkx \
273273 -mode yarn-session \
274274 -jobType sync \
275- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
275+ -job flinkx-examples /json/stream/stream.json \
276276 -flinkConfDir $FLINK_HOME /conf \
277277 -flinkxDistDir flinkx-dist \
278278 -hadoopConfDir $HADOOP_HOME /etc/hadoop
@@ -292,7 +292,7 @@ bin/flinkx \
292292bin/flinkx \
293293 -mode yarn-per-job \
294294 -jobType sync \
295- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
295+ -job flinkx-examples /json/stream/stream.json \
296296 -flinkxDistDir flinkx-dist \
297297 -flinkConfDir $FLINK_HOME /conf \
298298 -hadoopConfDir $HADOOP_HOME /etc/hadoop \
@@ -306,7 +306,7 @@ bin/flinkx \
306306bin/flinkx \
307307 -mode yarn-per-job \
308308 -jobType sync \
309- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
309+ -job flinkx-examples /json/stream/stream.json \
310310 -flinkxDistDir flinkx-dist \
311311 -hadoopConfDir $HADOOP_HOME /etc/hadoop \
312312 -flinkLibDir $FLINK_HOME /lib \
@@ -331,7 +331,7 @@ bin/flinkx \
331331bin/flinkx \
332332 -mode kubernetes-session \
333333 -jobType sync \
334- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
334+ -job flinkx-examples /json/stream/stream.json \
335335 -jobName kubernetes-job \
336336 -jobType sync \
337337 -flinkxDistDir flinkx-dist \
@@ -354,7 +354,7 @@ $FLINK_HOME/bin/kubernetes-session.sh -Dkubernetes.cluster-id=flink-session-test
354354bin/flinkx \
355355 -mode kubernetes-application \
356356 -jobType sync \
357- -job flinkx-local-test/src/main/demo /json/stream/stream.json \
357+ -job flinkx-examples /json/stream/stream.json \
358358 -jobName kubernetes-job \
359359 -jobType sync \
360360 -flinkxDistDir flinkx-dist \
0 commit comments