You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2018/10/22 23:48:34 UTC
[3/3] samza git commit: Adding fix to integration test
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/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: rmatharu@linkedin.com <rm...@linkedin.com>
Authored: Mon Oct 22 16:29:34 2018 -0700
Committer: Prateek Maheshwari <pm...@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)