-
Notifications
You must be signed in to change notification settings - Fork 22
Cannot submit jobs to Flink #255
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
Comments
Alright, new thing I'm going to try is using versions EXACTLY as they were in that other issue about a similar thing and see if I can at least make some progress towards getting this to work. I'm too stupid about Classpath stuff in general to understand what's happening and what needs to happen |
Same problem. |
Have you tried to remove scala package from this property Flink configuration property?
|
yes, didn't work either. I can run via the Java API with Scala fwiw, so I may just lean into that. I'm confused why the UberJar with the library wouldn't work, likewise with all the other variety of ways of passing the scala libs to the classpath. |
Could you describe where do you deploy Flink fat JAR? It is on-prem Flink Standalone cluster? |
Just the local cluster |
let me try with latest version. I guess by local cluster you mean Flink standalone mode like this https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/resource-providers/standalone/overview/ and not something else. I guess we need to prepare some docker-compose example to prevent people from being stuck at the very beginning. |
Hey There,
I was just trying this out via the Giter template. I followed the instructions to remove the scala_2.12 jar from the flink/lib directory and set the class-loader pattern to exclude scala.
I've tried both adding the scala 2.13 and scala 3 library jars to the flink/lib folder, as well as manually passing them both + individually to the flink run command.
Either I get an error related to not finding Scala libs at all.
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Scala products are used but Scala API is not on the classpath.
Or some missing path like
scala/collection/immutable
orscala/runtime/Nothing
I have tried this with both Flink 2.0.0 and Flink 1.20.1
sbt run
works and prints out the wordCount outputThe text was updated successfully, but these errors were encountered: