[BEAM-8471] Put back FlinkJobServerDriver.fromParams to fix post commit#9911
[BEAM-8471] Put back FlinkJobServerDriver.fromParams to fix post commit#9911tweise merged 1 commit intoapache:masterfrom
Conversation
|
follow-up from #9872 |
|
Run Java Flink PortableValidatesRunner Streaming |
|
Any reason we can't change |
Definitely worthwhile to investigate as follow-up. I don't like that fromXXX spaghetti and was trying to reduce it a bit. Will still need reflection to instantiate the class though. |
Right, but we could add |
ibzib
left a comment
There was a problem hiding this comment.
Anyway, your changes LGTM. I don't think we need to change too much to improve the interface stuff, but if you don't want to do that here I can do it in a follow-up.
Go for it. What I did was to make something else work, it would be good to do a focussed cleanup. |
|
Filed https://issues.apache.org/jira/browse/BEAM-8509 as a follow-up. |
https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/testReport/org.apache.beam.sdk/PipelineTest/testTupleInjectionTransform/
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
R: @username).[BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replaceBEAM-XXXwith the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.See the Contributor Guide for more tips on how to make review process smoother.
Post-Commit Tests Status (on master branch)
Pre-Commit Tests Status (on master branch)
See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.