You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/10/22 23:29:55 UTC
samza git commit: Adding fix to integration test
Repository: samza
Updated Branches:
refs/heads/master e203db2aa -> 0176138a1
Adding fix to integration test
ClientHelper changed the log-print, which the integration test relies on.
Author: rmatharu@linkedin.com <rm...@linkedin.com>
Reviewers: Jagadish<ja...@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/0176138a
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/0176138a
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/0176138a
Branch: refs/heads/master
Commit: 0176138a1680ac77c2894e0bd09bb046ba96a7df
Parents: e203db2
Author: rmatharu@linkedin.com <rm...@linkedin.com>
Authored: Mon Oct 22 16:29:34 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Mon Oct 22 16:29:34 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/0176138a/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)