flink-1.10.0通过run -m yarn-cluster提交任务时异常

[amenhub <am...@163.com>]

各位好，


    The program finished with the following exception:

    java.lang.IllegalArgumentException: The given host:port ('yarn-cluster') doesn't contain a valid port

    at org.apache.flink.util.NetUtils.validateHostPortString(NetUtils.java:108)

    at org.apache.flink.util.NetUtils.parseHostPortAddress(NetUtils.java:88)


祝好！

Re: Re: flink-1.10.0通过run -m yarn-cluster提交任务时异常

[tison <wa...@gmail.com>]

常见问题。

现在 Flink 不 bundle hadoop，所以你要设置下 HADOOP_CLASSPATH

Best,
tison.


amenhub <am...@163.com> 于2020年2月18日周二 上午11:51写道：

> hi, Weihua
>
>
> 如你所说，我想要通过flink on yarn的run方式提交任务到集群上，但是当我运行./bin/flink run -m
> yarn-cluster ../examples/batch/WordCount.jar ，还是一样的错误，
> 日志信息只有这么一些；如果按您所说，是因为没有成功加载FlinkYarnSessionCli导致的，那导致没有成功加载的原因有哪些方面呢？谢谢！
>
>
> 祝好，amenhub
>
>
>
>
>
>
>
> 在 2020-02-18 11:29:13，"Weihua Hu" <hu...@gmail.com> 写道：
> >Hi, amenhub
> >
> >你应该是要把作业提交到 yarn 上吧。这个错误应该没有正确的加载 FlinkYarnSessionCli
> 导致的，这些日志不是失败的根因。可以多提供一些日志看看。
> >
> >
> >Best
> >Weihua Hu
> >
> >> 2020年2月18日 10:56，amenhub <am...@163.com> 写道：
> >>
> >> parseHostPortAddress
> >
>

Re:Re: flink-1.10.0通过run -m yarn-cluster提交任务时异常

[amenhub <am...@163.com>]

hi, Weihua


如你所说，我想要通过flink on yarn的run方式提交任务到集群上，但是当我运行./bin/flink run -m yarn-cluster ../examples/batch/WordCount.jar ，还是一样的错误，
日志信息只有这么一些；如果按您所说，是因为没有成功加载FlinkYarnSessionCli导致的，那导致没有成功加载的原因有哪些方面呢？谢谢！


祝好，amenhub







在 2020-02-18 11:29:13，"Weihua Hu" <hu...@gmail.com> 写道：
>Hi, amenhub
>
>你应该是要把作业提交到 yarn 上吧。这个错误应该没有正确的加载 FlinkYarnSessionCli 导致的，这些日志不是失败的根因。可以多提供一些日志看看。
>
>
>Best
>Weihua Hu
>
>> 2020年2月18日 10:56，amenhub <am...@163.com> 写道：
>> 
>> parseHostPortAddress
>

Re: flink-1.10.0通过run -m yarn-cluster提交任务时异常

[Weihua Hu <hu...@gmail.com>]

Hi, amenhub

你应该是要把作业提交到 yarn 上吧。这个错误应该没有正确的加载 FlinkYarnSessionCli 导致的，这些日志不是失败的根因。可以多提供一些日志看看。


Best
Weihua Hu

> 2020年2月18日 10:56，amenhub <am...@163.com> 写道：
> 
> parseHostPortAddress