[ 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)