-
Notifications
You must be signed in to change notification settings - Fork 2.8k
[ZEPPELIN-4790]. Throw exception when using flink for scala 2.12 #3763
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
Conversation
alexott
left a comment
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.
looks ok, although I'm not sure if we need to make it so complex.
| private String extractScalaVersion() throws InterpreterException { | ||
| String scalaVersionString = scala.util.Properties.versionString(); | ||
| LOGGER.info("Using Scala: " + scalaVersionString); | ||
| if (scalaVersionString.contains("version 2.10")) { | ||
| return "2.10"; | ||
| } else if (scalaVersionString.contains("version 2.11")) { | ||
| return "2.11"; | ||
| } else if (scalaVersionString.contains("version 2.12")) { | ||
| return "2.12"; | ||
| } else { | ||
| throw new InterpreterException("Unsupported scala version: " + scalaVersionString); | ||
| } |
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.
Do we plan to support multiple Scala versions in the future, and have some functionality depending on it?
Otherwise I would maybe just implement something like "isSupportedScalaVersion" with one check for Scala 2.11 as of now.
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.
addressed
alexott
left a comment
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.
LGTM
### What is this PR for? This PR will throw exception when using flink for scala 2.12 which is not supported now. See the screenshot below. ### What type of PR is it? [ Improvement ] ### Todos * [ ] - Task ### What is the Jira issue? * https://issues.apache.org/jira/browse/ZEPPELIN-4790 ### How should this be tested? * Manually tested. ### Screenshots (if appropriate)  ### Questions: * Does the licenses files need update? No * Is there breaking changes for older versions? No * Does this needs documentation? No Author: Jeff Zhang <[email protected]> Closes #3763 from zjffdu/ZEPPELIN-4790 and squashes the following commits: eac7b9a [Jeff Zhang] address comment 57b0737 [Jeff Zhang] [ZEPPELIN-4790]. Throw exception when using flink for scala 2.12 (cherry picked from commit e229682) Signed-off-by: Jeff Zhang <[email protected]>
What is this PR for?
This PR will throw exception when using flink for scala 2.12 which is not supported now. See the screenshot below.
What type of PR is it?
[ Improvement ]
Todos
What is the Jira issue?
How should this be tested?
Screenshots (if appropriate)
Questions: