run fink local



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

上一篇:iOS多线程编程之二——NSOperation与NSOperationQueue


下一篇:centos7 date 命令