You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/12/13 09:38:00 UTC

[jira] [Created] (FLINK-11148) Rescaling operator regression in Flink 1.7

Truong Duc Kien created FLINK-11148:
---------------------------------------

             Summary: Rescaling operator regression in Flink 1.7
                 Key: FLINK-11148
                 URL: https://issues.apache.org/jira/browse/FLINK-11148
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.7.0
            Reporter: Truong Duc Kien


We have a job using 20 TaskManager with 3 slot each.

Using Flink 1.4, when we rescale a data stream from 60 to 20, each TaskManager will only have one downstream slot, that receives the data from 3 upstream slots in the same TaskManager.

Using Flink 1.7, this behaviour no longer hold true, multiple downstream slots are being assigned to the same TaskManager. This change is causing imbalance in our TaskManager load.



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