Adding fix to integration test ClientHelper changed the log-print, which the integration test relies on.
Author: rmath...@linkedin.com <rmath...@linkedin.com> Reviewers: Jagadish<jagad...@apache.org> Closes #752 from rmatharu/integ-test-fix Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b8e7103b Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/b8e7103b Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/b8e7103b Branch: refs/heads/1.0.0 Commit: b8e7103be5479944d01a0fd7f5e0e94193b06dc8 Parents: 2782818 Author: rmath...@linkedin.com <rmath...@linkedin.com> Authored: Mon Oct 22 16:29:34 2018 -0700 Committer: Prateek Maheshwari <pmaheshw...@apache.org> Committed: Mon Oct 22 16:47:53 2018 -0700 ---------------------------------------------------------------------- samza-test/src/main/python/samza_job_yarn_deployer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/b8e7103b/samza-test/src/main/python/samza_job_yarn_deployer.py ---------------------------------------------------------------------- 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 e0e3274..405678f 100644 --- 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 @@ class SamzaJobYarnDeployer(Deployer): 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)