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

shengjk1 commented on FLINK-11725:
----------------------------------

i think two ways solve this issue:

1.Add judgment in org.apache.flink.client.cli.CliFrontend  if \{{-yn}} * 
\{{-ys}} < \{{-p}} system.exit(1)  and Print message: \{{-yn}} * \{{-ys}}  
shoule more than the \{{-p}}

2.Create taskManager with one solt until \{{-yn}} * \{{-ys}} >= \{{-p}}  as 
default

> use flink cli  when  {{-yn}} * {{-ys}} < {{-p}}, the applied resources are 
> erratic
> ----------------------------------------------------------------------------------
>
>                 Key: FLINK-11725
>                 URL: https://issues.apache.org/jira/browse/FLINK-11725
>             Project: Flink
>          Issue Type: Bug
>          Components: ResourceManager
>    Affects Versions: 1.7.2
>         Environment: flink1.7.2
> linux
> java8
> kafka1.1
>            Reporter: shengjk1
>            Priority: Major
>         Attachments: 1111.png, 2.png, 3.png, MainConnect3.java
>
>
> I provide a simple example and used resource's picture for this issue 
> this application is about flink consumer kafka,  when submit job such as : 
> flink-1.7.1/bin/flink  run -m yarn-cluster -yn 1   -ynm test -p 5  
> -cMainConnect3  ./flinkDemo-1.0-SNAPSHOT.jar &
> from yarn web ,i see, the total resources are erratic, and in most cases, all 
> the remaining resources of the cluster will be used by the application
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to