大数据之Apache Beam 使用Flink Runner管道参数

上帝大脸

　　
例子
Flink集群
mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount -Dexec.args="--runner=FlinkRunner --flinkMaster= --filesToStage=target/word-count-beam-bundled-0.1.jar --inputFile=/path/to/quickstart/pom.xml --output=/tmp/counts" -Pflink-runner
　　管道参数说明
　　

FieldDescriptionDefault ValuerunnerThe pipeline runner to use. This option allows you to determine the pipeline runner at runtime.Set to FlinkRunnerto run using Flink.streamingWhether streaming mode is enabled or disabled; true if enabled. Set to true if running pipelines with unbounded PCollections.falseflinkMasterThe url of the Flink JobManager on which to execute pipelines. This can either be the address of a cluster JobManager, in the form "host:port" or one of the special Strings "[local]" or "[auto]". "[local]" will start a local Flink Cluster in the JVM while "[auto]" will let the system decide where to execute the pipeline based on the environment.[auto]filesToStageJar Files to send to all workers and put on the classpath. Here you have to put the fat jar that contains your program along with all dependencies.emptyparallelismThe degree of parallelism to be used when distributing operations onto workers.1checkpointingIntervalThe interval between consecutive checkpoints (i.e. snapshots of the current pipeline state used for fault tolerance).-1L, i.e. disablednumberOfExecutionRetriesSets the number of times that failed tasks are re-executed. A value of 0 effectively disables fault tolerance. A value of -1 indicates that the system default value (as defined in the configuration) should be used.-1executionRetryDelaySets the delay between executions. A value of -1 indicates that the default value should be used.-1stateBackendSets the state backend to use in streaming mode. The default is to read this setting from the Flink config.empty, i.e. read from Flink config