首页 > 其他 > 详细

run fink local

时间:2021-09-09 16:50:34      阅读:24      评论:0      收藏:0      [点我收藏+]


Q: How to run fink local, please see
https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/local_installation.html

1 download flink-1.12.3-bin-scala_2.11.tgz

2 tar -xzf flink-1.12.3-bin-scala_2.11.tgz

3 cd flink

4 ./bin/start-cluster.sh

5 ./bin/stop-cluster.sh

-------------------------------------------------------------------------------------------------------

Q: How to run fink demo

1 mvn clean package

2 copy my-flink-project-0.1.jar and hello.txt into flink/example dir

3 chmod a+x my-flink-project-0.1.jar

4 cd flink

5 ./bin/flink run -c myflink.StreamWindowWordCount -p 1 ./examples/my-flink-project-0.1.jar ./examples/hello.txt

To use dependencies in ./lib dir

make dependencies in pom.xml ‘<scope>provided</scope>‘ and copy dependencies from your local repo into lib dir, then
./bin/flink run -c myflink.StreamWindowWordCount -C file://./lib/flink-java-1.12.1.jar,./flink-streaming-java_2.12-1.12.1.jar,./lib/flink-clients_2.12-1.12.1.jar,./lib/log4j-api-2.12.1.jar,./lib/log4j-core-2.12.1.jar,./lib/log4j-slf4j-impl-2.12.1.jar ./examples/my-flink-project-0.1.jar ./examples/hello.txt

To see result

tail -f log/flink-${who am i}-taskexecutor-0-${hostname}.out
or just open it with your text editor

-------------------------------------------------------------------------------------------------------

Q: How to run flink sql client
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sqlclient/

$FLINK_HOME/conf/flink-conf.yaml
classloader.resolve-order: parent-first

copy dependencies from your local repo in pom into lib dir
./bin/sql-client.sh embedded -l lib








run fink local

原文:https://www.cnblogs.com/tonggc1668/p/15246743.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!