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)

Reply via email to