-
Notifications
You must be signed in to change notification settings - Fork 64
New issue
Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? # to your account
[NEMO-364] Upgrade Beam version #204
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for your PR :)
Please check my comments.
examples/beam/src/main/java/org/apache/nemo/examples/beam/GenericSourceSink.java
Outdated
Show resolved
Hide resolved
break; | ||
} | ||
} | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What's this?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This was a patch for the bug on the Beam side, but it's been resolved after the 2.10.0 update. Here's the link: https://beam.apache.org/blog/2019/02/15/beam-2.10.0.html
Please refer to the line that says: SQL: JDBC driver no longer breaks interactions with other JDBC sources
@@ -247,7 +247,6 @@ public void saveOptimizationMetricsToDB(final String address, final String id, f | |||
|
|||
try (final Connection c = DriverManager.getConnection(address, id, passwd)) { | |||
LOG.info("Opened database successfully at {}", MetricUtils.POSTGRESQL_METADATA_DB_NAME); | |||
MetricUtils.deregisterBeamDriver(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
??
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same here.
Great! I'm good to merge it :) |
JIRA: NEMO-364: Upgrade Beam
Major changes:
Minor changes to note:
Tests for the changes:
Other comments:
Closes #204