You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/08 14:09:00 UTC
[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws
FlinkException indicating no cluster id was specified
[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Canbin Zheng updated FLINK-17055:
---------------------------------
Description:
The first command works fine.
{code:java}
./bin/flink list -m yarn-cluster -yid application_1580534782944_0015
{code}
The second command throws an Exception.
{code:java}
./bin/flink list -e yarn-per-job -yid application_1580534782944_0015
{code}
And the exception stack is:
org.apache.flink.util.FlinkException: No cluster id was specified. Please specify a cluster to which you would like to connect.
at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:836)
at org.apache.flink.client.cli.CliFrontend.list(CliFrontend.java:334)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:896)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:966)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:966)
was:
The first command works fine.
{code:java}
./bin/flink list -m yarn-cluster -yid application_1580534782944_0015
{code}
The second command throws an Exception.
{code:java}
./bin/flink list -e yarn-per-job -yid application_1580534782944_0015
{code}
And the exception stack is:
> The program finished with the following exception:
> org.apache.flink.util.FlinkException: No cluster id was specified. Please specify a cluster to which you would like to connect.
> at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:836)
> at org.apache.flink.client.cli.CliFrontend.list(CliFrontend.java:334)
> at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:896)
> at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:966)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:422)
> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
> at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:966)
> List jobs via bin/flink throws FlinkException indicating no cluster id was specified
> ------------------------------------------------------------------------------------
>
> Key: FLINK-17055
> URL: https://issues.apache.org/jira/browse/FLINK-17055
> Project: Flink
> Issue Type: Bug
> Components: Command Line Client
> Affects Versions: 1.10.0
> Reporter: Canbin Zheng
> Priority: Major
>
> The first command works fine.
> {code:java}
> ./bin/flink list -m yarn-cluster -yid application_1580534782944_0015
> {code}
> The second command throws an Exception.
> {code:java}
> ./bin/flink list -e yarn-per-job -yid application_1580534782944_0015
> {code}
> And the exception stack is:
> org.apache.flink.util.FlinkException: No cluster id was specified. Please specify a cluster to which you would like to connect.
> at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:836)
> at org.apache.flink.client.cli.CliFrontend.list(CliFrontend.java:334)
> at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:896)
> at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:966)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:422)
> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
> at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:966)
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)