[samza] branch master updated: SAMZA-2225: Update configurations in standalone integration tests. (#1054)

[sh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

shanthoosh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 55f60df  SAMZA-2225: Update configurations in standalone integration tests. (#1054)
55f60df is described below

commit 55f60df0e272e205b2daf443fb2ec38c6e7ffd65
Author: shanthoosh <sp...@usc.edu>
AuthorDate: Tue May 28 17:06:50 2019 -0700

    SAMZA-2225: Update configurations in standalone integration tests. (#1054)
    
    * Fix zookeeper base path in standalone integration tests.
    
    * Fix the version number in the executable.
---
 samza-test/src/main/python/stream_processor.py | 2 +-
 samza-test/src/main/python/tests/zk_client.py  | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/samza-test/src/main/python/stream_processor.py b/samza-test/src/main/python/stream_processor.py
index dacd59c..6d4353e 100644
--- a/samza-test/src/main/python/stream_processor.py
+++ b/samza-test/src/main/python/stream_processor.py
@@ -43,7 +43,7 @@ class StreamProcessor:
         logger.info('Running processor start command: {0}'.format(self.processor_start_command))
         self.deployment_config = {
             'install_path': os.path.join(runtime.get_active_config('remote_install_path'), 'deploy/{0}'.format(self.processor_id)),
-            'executable': 'samza-test_2.11-1.0.1-SNAPSHOT.tgz',
+            'executable': 'samza-test_2.11-1.1.1-SNAPSHOT.tgz',
             'post_install_cmds': [],
             'start_command': self.processor_start_command,
             'stop_command': '',
diff --git a/samza-test/src/main/python/tests/zk_client.py b/samza-test/src/main/python/tests/zk_client.py
index 006d84f..f5716e4 100644
--- a/samza-test/src/main/python/tests/zk_client.py
+++ b/samza-test/src/main/python/tests/zk_client.py
@@ -31,8 +31,9 @@ class ZkClient:
     Instantiates a kazoo client to connect to zookeeper server at :param zookeeper_host::param zookeeper_port.
     """
     def __init__(self, zookeeper_host, zookeeper_port, app_name, app_id):
+        self.protocol_version = "1.0"
         self.kazoo_client = KazooClient(hosts='{0}:{1}'.format(zookeeper_host, zookeeper_port))
-        self.zk_base_node = 'app-{0}-{1}/{2}-{3}-coordinationData'.format(app_name, app_id, app_name, app_id)
+        self.zk_base_node = 'app-{0}-{1}/{2}-{3}-{4}-coordinationData'.format(app_name, app_id, app_name, app_id, self.protocol_version)
 
     def start(self):
         """