-
Notifications
You must be signed in to change notification settings - Fork 13.1k
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
[FLINK-4108] [scala] Consider ResultTypeQueryable for input formats #2619
Conversation
Works OK ¡¡ Thanks, Alb |
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.
PR looks good to me.
+1 to merge once the unnecessary change is reverted.
@@ -110,7 +110,7 @@ class ExecutionEnvironment(javaEnv: JavaEnv) { | |||
*/ | |||
@PublicEvolving | |||
def getRestartStrategy: RestartStrategyConfiguration = { | |||
javaEnv.getRestartStrategy() | |||
javaEnv.getRestartStrategy |
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.
We call methods on Java objects with parentheses.
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.
Apparently this is not the case in this class. Similar method are also called without parentheses. So lets keep this change to have consistent code in this class.
Merging |
Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the How To Contribute guide.
In addition to going through the list, please provide a meaningful description of your changes.
mvn clean verify
has been executed successfully locally or a Travis build has passedThis PR fixes issues with input formats (i.e. the JDBC input format) in the Scala API. Now the API also considers explicit information defines with ResultTypeQueryable.