Adding fix to integration test

ClientHelper changed the log-print, which the integration test relies on. Author: [email protected] <[email protected]> Reviewers: Jagadish<[email protected]> Closes apache#752 from rmatharu/integ-test-fix
shanthoosh · Oct 22, 2018 · 0176138 · 0176138
1 parent e203db2
commit 0176138
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/samza-test/src/main/python/samza_job_yarn_deployer.py b/samza-test/src/main/python/samza_job_yarn_deployer.py
@@ -136,7 +136,8 @@ def start(self, job_id, configs={}):
     assert p.returncode == 0, "Command ({0}) returned non-zero exit code ({1}).\nstdout: {2}\nstderr: {3}".format(command, p.returncode, output, err)
 
     # Save application_id for job_id so we can kill the job later.
-    regex = r'.*Submitted application (\w*)'
+    # In case of tests, this is populated by ClientHelper
+    regex = r'.*submitting application request for (\w*)'
     match = re.match(regex, output.replace("\n", ' '))
     assert match, "Job ({0}) appears not to have started. Expected to see a log line matching regex: {1}".format(job_id, regex)
     app_id = match.group(1)