You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@beam.apache.org by 鲍曦曦 <ba...@126.com> on 2017/10/21 12:42:21 UTC

需要beam的支持 Need Support 问题:官网例子 flink-cluster模式执行 失败

你好,beam 官网的例子 
我的flink 机器的主节点 地址 flinkMaster=10.47.152.16
我使用一台服务器跑,具体过程如下
第一步》执行官方命令
mvn archetype:generate \
      -DarchetypeGroupId=org.apache.beam \
      -DarchetypeArtifactId=beam-sdks-java-maven-archetypes-examples \
      -DarchetypeVersion=2.1.0 \
      -DgroupId=org.example \
      -DartifactId=word-count-beam \
      -Dversion="0.1" \
      -Dpackage=org.apache.beam.examples \
      -DinteractiveMode=false
第二步执行》
mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
     -Dexec.args="--runner=FlinkRunner --flinkMaster==10.47.152.16  --filesToStage=target/word-count-beam-bundled-0.1.jar \
                  --inputFile=/home/admin/word-count-beam/pom.xml --output=/tmp/counts" -Pflink-runner


第三步》查询结果 正确  附近是详细执行日志


问题》 为什么 我的flink集群 主节点没有任何日志更新




请问中国有支持团队吗? qq群或者啥的。能加我到讨论组吗?   Thans very much