Maybe the problem is here? cc Till

https://github.com/apache/flink/blob/44ed5ef0fc1c221f3916ab5126f1bc8ee5dfb45d/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnEntrypointUtils.java#L83
https://github.com/apache/flink/blob/44ed5ef0fc1c221f3916ab5126f1bc8ee5dfb45d/flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnEntrypointUtils.java#L101




Jeff Zhang <zjf...@gmail.com> ezt írta (időpont: 2018. dec. 5., Sze, 13:13):

> This requirement makes sense to me. Another issue I hit due to single
> value of rest port is that user can not start 2 local MiniCluster, I try to
> start 2 flink scala-shell in local mode, but fails due to port conflict.
>
>
>
> Gyula Fóra <gyula.f...@gmail.com> 于2018年12月5日周三 下午8:04写道:
>
>> Hi!
>> Is there any way currently to set a port range for the rest client?
>> rest.port only takes a single number and it is anyways overwritten to 0.
>>
>> This seems to be necessary when running the flink client from behind a
>> firewall where only a predefined port-range is accessible from the outside.
>>
>> I would assume this is a common setup in prod environments. This hasn't
>> been a problem with the legacy execution mode.
>>
>> Any thoughts?
>> Gyula
>>
>
>
> --
> Best Regards
>
> Jeff Zhang
>

Reply via email to