flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yazdan Shirvany (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9848) When Parallelism more than available task slots Flink stays idle
Date Fri, 13 Jul 2018 20:46:00 GMT

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

Yazdan Shirvany commented on FLINK-9848:
----------------------------------------

Actually I re-tried with multiple examples and seems only {{batch/WordCount.jar}} can be successful
when {{parallelism > available slots}}

> When Parallelism more than available task slots Flink stays idle
> ----------------------------------------------------------------
>
>                 Key: FLINK-9848
>                 URL: https://issues.apache.org/jira/browse/FLINK-9848
>             Project: Flink
>          Issue Type: Bug
>          Components: Cluster Management
>    Affects Versions: 1.5.0, 1.5.1
>            Reporter: Yazdan Shirvany
>            Assignee: Yazdan Shirvany
>            Priority: Critical
>
> For version 1.4.x when select Parallelism > Available task Slots, Flink throw bellow
error right away 
> {{NoResourceAvailableException: Not enough free slots available to run the job}}
>   
>  but for version 1.5.x there are two different behaviors: Sometimes job ran successfully
and sometimes it throw bellow error after 5 minutes 
>  
> {{org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not
allocate all requires slots within timeout of 300000 ms. Slots required: 5, slots allocated:
2}}



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

Mime
View raw message