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

Aljoscha Krettek commented on FLINK-14834:
------------------------------------------

Something very strange is going on. When I try this on a (dockerized) YARN 
cluster the job sometimes needs 3 slots to run and sometimes needs 4 slots. I 
run this job:

{code}
bin/flink run -m yarn-cluster -p 3 -yjm 2000 -ytm 2000 
examples/streaming/WordCount.jar --input hdfs:///wc-in-1 --input 
hdfs:///wc-in-2 --output hdfs:///wc-out
{code}

The attached logs show the (DEBUG) jobmanager.log of two different runs. Try 
searching for "Requesting new slot".

> Kerberized YARN on Docker test (default input) fails on Travis
> --------------------------------------------------------------
>
>                 Key: FLINK-14834
>                 URL: https://issues.apache.org/jira/browse/FLINK-14834
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / YARN, Runtime / Coordination, Tests
>    Affects Versions: 1.10.0
>            Reporter: Gary Yao
>            Assignee: Aljoscha Krettek
>            Priority: Blocker
>              Labels: test-stability
>             Fix For: 1.10.0
>
>         Attachments: run-with-3-slots.txt, run-with-4-slots.txt
>
>
> https://api.travis-ci.org/v3/job/612782888/log.txt



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to