Update Beam to 2.27 and samza to 1.3 (#3)
diff --git a/README.md b/README.md
index fa4c2f9..d322d19 100644
--- a/README.md
+++ b/README.md
@@ -73,7 +73,7 @@
```
$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.KafkaWordCount \
- -Dexec.args="--runner=SamzaRunner" -P samza-runner
+ -Dexec.args="--runner=SamzaRunner --experiments=use_deprecated_read" -P samza-runner
```
#### Packaging Your Application
diff --git a/pom.xml b/pom.xml
index 2689de3..6364f4f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,8 +27,8 @@
<packaging>jar</packaging>
<properties>
- <beam.version>2.11.0</beam.version>
- <samza.version>0.14.1</samza.version>
+ <beam.version>2.27.0</beam.version>
+ <samza.version>1.3.0</samza.version>
<guava.version>20.0</guava.version>
<hamcrest.version>1.3</hamcrest.version>
@@ -182,7 +182,7 @@
<dependency>
<groupId>org.apache.samza</groupId>
- <artifactId>samza-log4j</artifactId>
+ <artifactId>samza-log4j_2.11</artifactId>
<version>${samza.version}</version>
</dependency>
@@ -210,6 +210,12 @@
<version>${samza.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <version>2.0.1</version>
+ </dependency>
+
<!-- Dependencies below this line are specific dependencies needed by the examples code. -->
<dependency>
<groupId>joda-time</groupId>
diff --git a/src/main/bash/run-beam-container.sh b/src/main/bash/run-beam-container.sh
index 4e9f8d9..0c70f38 100755
--- a/src/main/bash/run-beam-container.sh
+++ b/src/main/bash/run-beam-container.sh
@@ -33,4 +33,4 @@
override="{\"task.execute\":\"bin/run-beam-container.sh $@\"}"
-exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configFactory=org.apache.beam.runners.samza.container.ContainerCfgFactory --configOverride="$override" "${@:2}"
\ No newline at end of file
+exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configFactory=org.apache.beam.runners.samza.container.ContainerCfgFactory --configOverride="$override" --samzaExecutionEnvironment=YARN --experiments=use_deprecated_read "${@:2}"
\ No newline at end of file
diff --git a/src/main/bash/run-beam-standalone.sh b/src/main/bash/run-beam-standalone.sh
index 88bd43c..47b00bb 100755
--- a/src/main/bash/run-beam-standalone.sh
+++ b/src/main/bash/run-beam-standalone.sh
@@ -20,4 +20,4 @@
override="{\"task.execute\":\"bin/run-beam-container.sh $@\"}"
-exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" "${@:2}"
\ No newline at end of file
+exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" --experiments=use_deprecated_read "${@:2}"
\ No newline at end of file
diff --git a/src/main/bash/run-beam-yarn.sh b/src/main/bash/run-beam-yarn.sh
index 0e1df52..e467ebe 100755
--- a/src/main/bash/run-beam-yarn.sh
+++ b/src/main/bash/run-beam-yarn.sh
@@ -33,7 +33,7 @@
case $op in
run)
- exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" "${@:2}"
+ exec $(dirname $0)/run-class.sh $1 --runner=org.apache.beam.runners.samza.SamzaRunner --configOverride="$override" --samzaExecutionEnvironment=YARN --experiments=use_deprecated_read "${@:2}"
;;
kill)
