flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-9146) 1.4 more than local cannot start submitting
Date Thu, 09 May 2019 07:49:00 GMT

     [ 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)

Mime
View raw message