SAMZA-2723: Fix yarn version and scala version for scalate (#1586)
* Fix yarn version and scala version for scalate
* Fix standalone integ tests
diff --git a/bin/check-all.sh b/bin/check-all.sh
index b0fe75b..1541f29 100755
--- a/bin/check-all.sh
+++ b/bin/check-all.sh
@@ -23,7 +23,7 @@
SCALAs=( "2.11" "2.12" )
JDKs=( "JAVA8_HOME" )
-YARNs=( "2.6.1" "2.7.1" )
+YARNs=( "2.10.1" )
# get base directory
home_dir=`pwd`
diff --git a/gradle/dependency-versions-scala-2.12.gradle b/gradle/dependency-versions-scala-2.12.gradle
index c1a8d06..50fc4dc 100644
--- a/gradle/dependency-versions-scala-2.12.gradle
+++ b/gradle/dependency-versions-scala-2.12.gradle
@@ -18,7 +18,7 @@
*/
ext {
scalaSuffix = "2.12"
- scalaVersion = "2.12.1"
+ scalaVersion = "2.12.11"
// Extra options for the compiler:
// -feature: Give detailed warnings about language feature use (rather than just 'there were 4 warnings')
// -language:implicitConversions: Allow the use of implicit conversions without warning or library import
diff --git a/samza-test/src/main/python/tests/standalone_failure_tests.py b/samza-test/src/main/python/tests/standalone_failure_tests.py
index 0fab742..ee8f8a9 100644
--- a/samza-test/src/main/python/tests/standalone_failure_tests.py
+++ b/samza-test/src/main/python/tests/standalone_failure_tests.py
@@ -104,9 +104,9 @@
def __validate_job_model(job_model, killed_processors=[]):
## Validate the TaskModel. Check if all the partitions are assigned to the containers.
- expected_ssps = [{u'partition': 0, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'},
- {u'partition': 1, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'},
- {u'partition': 2, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'}]
+ expected_ssps = [{u'keyBucket': -1, u'partition': 0, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'},
+ {u'keyBucket': -1, u'partition': 1, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'},
+ {u'keyBucket': -1, u'partition': 2, u'system': u'testSystemName', u'stream': u'standalone_integration_test_kafka_input_topic'}]
actual_ssps = []
for container_id, tasks in job_model['containers'].iteritems():
for partition, ssps in tasks['tasks'].iteritems():
