SAMZA-970 : Problems with integration tests
authorXinyu Liu <xiliu@linkedin.com>
Fri, 29 Jul 2016 19:08:34 +0000 (12:08 -0700)
committerNavina Ramesh <nramesh@linkedin.com>
Fri, 29 Jul 2016 19:08:34 +0000 (12:08 -0700)
bin/integration-tests.sh
samza-test/src/main/python/configs/tests.json
samza-test/src/main/python/requirements.txt
samza-test/src/main/python/samza_job_yarn_deployer.py

index af00b5f..7ed8dae 100755 (executable)
@@ -51,7 +51,7 @@ cp ./samza-test/build/distributions/samza-test*.tgz $ABS_TEST_DIR
 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
index 30be820..8feb5b9 100644 (file)
@@ -1,5 +1,5 @@
 {
-  "samza_executable": "samza-test_2.10-0.10.0-SNAPSHOT.tgz",
+  "samza_executable": "samza-test_2.10-0.11.0-SNAPSHOT.tgz",
   "samza_install_path": "deploy/smoke_tests",
   "samza_config_factory": "org.apache.samza.config.factories.PropertiesConfigFactory"
 }
index 2ae9590..e1f8c49 100644 (file)
@@ -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
index 38635ca..e0e3274 100644 (file)
@@ -276,6 +276,9 @@ class SamzaJobYarnDeployer(Deployer):
   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)