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