[jira] [Commented] (FLINK-13744) Improper error message when submit flink job in yarn-cluster mode without hadoop lib bundled

["Till Rohrmann (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-13744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908912#comment-16908912 ] 

Till Rohrmann commented on FLINK-13744:
---------------------------------------

Thanks for reporting this issue [~zjffdu]. I think this might be an artifact of how the {{CustomCommandLines}} and the {{CliFrontend}} work. 

We could add a filter to the {{DefaultCLI}} which prints a better exception message if it detects that we pass in {{yarn-cluster}}.

Could you work on this?



> Improper error message when submit flink job in yarn-cluster mode without hadoop lib bundled
> --------------------------------------------------------------------------------------------
>
>                 Key: FLINK-13744
>                 URL: https://issues.apache.org/jira/browse/FLINK-13744
>             Project: Flink
>          Issue Type: Improvement
>          Components: Command Line Client
>    Affects Versions: 1.9.0
>            Reporter: Jeff Zhang
>            Priority: Minor
>
> Here's the error message I see when I submit flink job in yarn-cluster mode. The root cause is that I didn't build flink with profile include-hadoop. But the error message here doesn't tell user what's wrong here. We should improve the error message in this case.
>  
> {code:java}
> ➜  build-target git:(FLINK-13415) ✗ bin/flink run -m yarn-cluster examples/batch/WordCount.jar
> ------------------------------------------------------------
>  The program finished with the following exception:
> java.lang.RuntimeException: Could not identify hostname and port in 'yarn-cluster'.
> 	at org.apache.flink.client.ClientUtils.parseHostPortAddress(ClientUtils.java:47)
> 	at org.apache.flink.client.cli.AbstractCustomCommandLine.applyCommandLineOptionsToConfiguration(AbstractCustomCommandLine.java:83)
> 	at org.apache.flink.client.cli.DefaultCLI.createClusterDescriptor(DefaultCLI.java:60)
> 	at org.apache.flink.client.cli.DefaultCLI.createClusterDescriptor(DefaultCLI.java:35)
> 	at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:216)
> 	at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205)
> 	at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)
> 	at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
> 	at org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
> 	at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)