Skip to content
Snippets Groups Projects
Commit 2c1ea404 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Add environment variables config to beam samza

parent df125ad6
Branches
Tags
1 merge request!187Migrate Beam benchmark implementation
# runner # runner
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
job.config.rewriters=env-config
job.config.rewriter.env-config.class=org.apache.samza.config.EnvironmentConfigRewriter
# zk # zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 #job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181
......
# runner # runner
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
job.config.rewriters=env-config
job.config.rewriter.env-config.class=org.apache.samza.config.EnvironmentConfigRewriter
# zk # zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 #job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181
......
# runner # runner
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
job.config.rewriters=env-config
job.config.rewriter.env-config.class=org.apache.samza.config.EnvironmentConfigRewriter
# zk # zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 #job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181
......
# runner # runner
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
job.config.rewriters=env-config
job.config.rewriter.env-config.class=org.apache.samza.config.EnvironmentConfigRewriter
# zk # zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 #job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment