Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[BEAM-14492] add flinkConfDir to FlinkPipelineOptions #17715

Merged
merged 1 commit into from
May 26, 2022

Conversation

je-ik
Copy link
Contributor

@je-ik je-ik commented May 19, 2022

Fixes [BEAM-14492]


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

  • Choose reviewer(s) and mention them in a comment (R: @username).
  • Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.
  • Update CHANGES.md with noteworthy changes.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

See the Contributor Guide for more tips on how to make review process smoother.

To check the build health, please visit https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels
Python tests
Java tests

See CI.md for more information about GitHub Actions CI.

@je-ik je-ik requested a review from dmvk May 19, 2022 13:24
@je-ik
Copy link
Contributor Author

je-ik commented May 19, 2022

Run Java PreCommit

2 similar comments
@je-ik
Copy link
Contributor Author

je-ik commented May 20, 2022

Run Java PreCommit

@je-ik
Copy link
Contributor Author

je-ik commented May 23, 2022

Run Java PreCommit

@je-ik
Copy link
Contributor Author

je-ik commented May 23, 2022

cc @dmvk

@je-ik
Copy link
Contributor Author

je-ik commented May 25, 2022

Run Java PreCommit

Copy link
Member

@dmvk dmvk left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@@ -285,6 +285,14 @@

void setFasterCopy(Boolean fasterCopy);

@Description(
"Directory containing Flink YAML configuration files. "
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

would be great if we can make it even more explicit that the configuration is only applied during JobGraph construction and doesn't affect the cluster configuration in any way.

nit: It would be great the description could be a constant that is used for both java and portable runner (to make sure these won't diverge by mistake)

@je-ik je-ik merged commit c5e521a into apache:master May 26, 2022
@je-ik je-ik deleted the BEAM-14492 branch May 26, 2022 07:13
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants