[SAMZA-2403] standalone integration failure: KeyError: 'containers'

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3
• Assignee: Hai Lu
• Reporter: Hai Lu
• Created: 26/Nov/19 23:04
• Updated: 27/Nov/19 01:23
• Resolved: 27/Nov/19 01:22

Description

2019-11-26 14:05:35,767 zk_client [ERROR] Traceback (most recent call last):
File "/home/halu/apache/old/samza/scripts/tests/zk_client.py", line 60, in get_latest_job_model
childZkNodes = self.kazoo_client.get_children('{0}/jobModelGeneration/jobModels/'.format(self.zk_base_node))
File "/home/halu/apache/old/samza/samza-integration-tests/lib/python2.7/site-packages/kazoo/client.py", line 1096, in get_children
include_data=include_data).get()
File "/home/halu/apache/old/samza/samza-integration-tests/lib/python2.7/site-packages/kazoo/handlers/utils.py", line 79, in get
raise self._exception
NoNodeError

Other messages:
Traceback (most recent call last):
File "/home/halu/apache/old/samza/samza-integration-tests/lib/python2.7/site-packages/zopkio/test_runner.py", line 445, in _run_and_verify_test
test.function()
File "/home/halu/apache/old/samza/scripts/tests/standalone_failure_tests.py", line 141, in test_kill_leader
job_model = __get_job_model(expected_processors=processors.keys())
File "/home/halu/apache/old/samza/scripts/tests/standalone_failure_tests.py", line 125, in __get_job_model
zk_client.watch_job_model(job_model_watcher(event=event, expected_processors=expected_processors))
File "/home/halu/apache/old/samza/scripts/tests/standalone_failure_tests.py", line 98, in job_model_watcher
if set(recent_job_model['containers'].keys()) == set(expected_processors):
KeyError: 'containers'

Issue Links

• links to: GitHub Pull Request #1225