SAMZA-970 - Problems with integration tests
diff --git a/bin/integration-tests.sh b/bin/integration-tests.sh
index af00b5f..7ed8dae 100755
--- a/bin/integration-tests.sh
+++ b/bin/integration-tests.sh
@@ -51,7 +51,7 @@
cd $ABS_TEST_DIR
# setup virtualenv locally if it's not already there
-VIRTUAL_ENV=virtualenv-12.0.2
+VIRTUAL_ENV=virtualenv-15.0.1
if [[ ! -d "${ABS_TEST_DIR}/${VIRTUAL_ENV}" ]] ; then
curl -O https://pypi.python.org/packages/source/v/virtualenv/$VIRTUAL_ENV.tar.gz
tar xvfz $VIRTUAL_ENV.tar.gz
diff --git a/samza-test/src/main/python/configs/tests.json b/samza-test/src/main/python/configs/tests.json
index 30be820..d584c57 100644
--- a/samza-test/src/main/python/configs/tests.json
+++ b/samza-test/src/main/python/configs/tests.json
@@ -1,5 +1,5 @@
{
- "samza_executable": "samza-test_2.10-0.10.0-SNAPSHOT.tgz",
+ "samza_executable": "samza-test_2.10-0.10.1-SNAPSHOT.tgz",
"samza_install_path": "deploy/smoke_tests",
"samza_config_factory": "org.apache.samza.config.factories.PropertiesConfigFactory"
}
diff --git a/samza-test/src/main/python/requirements.txt b/samza-test/src/main/python/requirements.txt
index 2ae9590..e1f8c49 100644
--- a/samza-test/src/main/python/requirements.txt
+++ b/samza-test/src/main/python/requirements.txt
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-zopkio
+zopkio==0.2.5
requests
-kafka-python
+kafka-python==1.2.5
Jinja2
diff --git a/samza-test/src/main/python/samza_job_yarn_deployer.py b/samza-test/src/main/python/samza_job_yarn_deployer.py
index 38635ca..e0e3274 100644
--- a/samza-test/src/main/python/samza_job_yarn_deployer.py
+++ b/samza-test/src/main/python/samza_job_yarn_deployer.py
@@ -276,6 +276,9 @@
def get_logs(self, container_id, logs, directory):
raise NotImplementedError
+ def kill_all_process(self):
+ pass
+
def _validate_configs(self, configs, config_keys):
for required_config in config_keys:
assert configs.get(required_config), 'Required config is undefined: {0}'.format(required_config)
