千家信息网

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

发表于:2024-11-16 作者:千家信息网编辑
千家信息网最后更新 2024年11月16日,例子Flink集群mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount -Dexec.args="--ru
千家信息网最后更新 2024年11月16日大数据之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 Value
runnerThe 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.false
flinkMasterThe 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.empty
parallelismThe degree of parallelism to be used when distributing operations onto workers.1
checkpointingIntervalThe interval between consecutive checkpoints (i.e. snapshots of the current pipeline state used for fault tolerance).-1L, i.e. disabled
numberOfExecutionRetriesSets 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.-1
executionRetryDelaySets the delay between executions. A value of -1 indicates that the default value should be used.-1
stateBackendSets 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



0