zoukankan      html  css  js  c++  java
  • 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








  • 相关阅读:
    hexo在git上搭建个人博客
    C++中的const
    C++ 面试 (1) 指针
    struct 大小计算
    php多路复用(多线程)socket相关应用
    centos6.5 redis应用环境搭建
    WebSocket的Cookie问题(转)
    java 获取参数泛型类型
    php编写TCP服务端和客户端程序
    phpize的作用(资料整理)
  • 原文地址:https://www.cnblogs.com/tonggc1668/p/15246743.html
Copyright © 2011-2022 走看看