[
https://issues.apache.org/jira/browse/FLINK-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9146.
-----------------------------------
Resolution: Invalid
You are using java 9+ as indicated by the stracktrace, which is not support by
Flink 1.4.
> 1.4 more than local cannot start submitting
> --------------------------------------------
>
> Key: FLINK-9146
> URL: https://issues.apache.org/jira/browse/FLINK-9146
> Project: Flink
> Issue Type: Bug
> Components: Command Line Client
> Affects Versions: 1.4.1, 1.4.2
> Environment: java version "1.8.0_102"
> Scala code runner version 2.11.8 -- Copyright 2002-2016, LAMP/EPFL
> flink 1.4.1
>
> Reporter: abel-sun
> Priority: Major
> Attachments: WechatIMG4550.jpeg, WechatIMG4551.jpeg
>
>
>
> Flink-1.4 quickstart address:
> [https://ci.apache.org/projects/flink/flink-docs-release-1.4/quickstart/setup_quickstart.html].
> When I use "./bin/start-local.sh" to start flink following flink-1.4's
> quickstart, then i check [http://localhost:8081/] and make sure everything is
> running,
> {code:java}
> //
> sunzhenya @ localhost in ~/Work/BigData/app/flink-1.4.1 [13:48:34] C:146
> $
> ./bin/flink run -c org.tko.log.flink.WordCount
> /Users/sunzhenya/Work/BigData/workspace/tko-log/target/tko-log-1.0-SNAPSHOT.jar
> WARNING: An illegal reflective access operation has occurred
> WARNING: Illegal reflective access by
> org.apache.hadoop.security.authentication.util.KerberosUtil
> (file:/Users/sunzhenya/Work/BigData/app/flink-1.4.1/lib/flink-shaded-hadoop2-uber-1.4.1.jar)
> to method sun.security.krb5.Config.getInstance()
> WARNING: Please consider reporting this to the maintainers of
> org.apache.hadoop.security.authentication.util.KerberosUtil
> WARNING: Use --illegal-access=warn to enable warnings of further illegal
> reflective access operations
> WARNING: All illegal access operations will be denied in a future release
> Cluster configuration: Standalone cluster with JobManager at
> localhost/127.0.0.1:6123
> Using address localhost:6123 to connect to JobManager.
> JobManager web interface address http://localhost:8081
> Starting execution of program
> Submitting job with JobID: 583cdaa12bc70a13e888608f9e23e9d9. Waiting for job
> completion.
> ------------------------------------------------------------
> The program finished with the following exception:
> org.apache.flink.client.program.ProgramInvocationException: The program
> execution failed: Couldn't retrieve the JobExecutionResult from the
> JobManager.
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:492)
> at
> org.apache.flink.client.program.StandaloneClusterClient.submitJob(StandaloneClusterClient.java:105)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:456)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:444)
> at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:62)
> at
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:815)
> at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
> at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
> at org.tko.log.flink.WordCount.main(WordCount.java:66)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:564)
> at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:525)
> at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:417)
> at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:396)
> at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:802)
> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:282)
> at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1054)
> at org.apache.flink.client.CliFrontend$1.call(CliFrontend.java:1101)
> {code}
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
