abel-sun created FLINK-9146:
-------------------------------
Summary: 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: Client
Affects Versions: 1.4.2, 1.4.1
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
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)
