[jira] [Created] (FLINK-9146) 1.4 more than local cannot start submitting

["abel-sun (JIRA)" <ji...@apache.org>]

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)