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

Mvn compiled jar cast an error when executing the examples #22

Open
paulakeen opened this issue Dec 1, 2020 · 1 comment
Open

Mvn compiled jar cast an error when executing the examples #22

paulakeen opened this issue Dec 1, 2020 · 1 comment

Comments

@paulakeen
Copy link

With the compiled jar, following exactly the instructions in the README.md file, i copied the example files in the directory containing the jar, and when executing either of these two lines it fails:

flink run -c io.rml.framework.Main ./RMLStreamer-2.0.1-SNAPSHOT.jar toFile --mapping-file ./mapping.ttl --output-path ./myoutput.nq

flink run ./RMLStreamer-2.0.1-SNAPSHOT.jar toFile --mapping-file ./mapping.ttl --output-path ./myoutput.nq

In both cases I get this exception:


The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)

...
etc.

@ghsnd
Copy link
Contributor

ghsnd commented Mar 3, 2021

Dear @paulakeen ,

Apologies for the late answer!
The exception gives not enough info to see what's going wrong here. Could you also provide Flink's logs, typically found in <Flink root dir>/logs?

Best regards,
Gerald

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants