rkhachatryan commented on PR #27440: URL: https://github.com/apache/flink/pull/27440#issuecomment-3777834866
Yes @1996fanrui, you're right. The purpose of this change is to prevent new input records from delaying the switch of the downstream tasks to RUNNING. This doesn't help in every case; an example where it is useful is two JOINed sources, where one of the channels has a lot of checkpointed buffers; and the other one is fast in producing new data (from source). In a sense, this is a lightweight alternative to FLIP-547. To my understanding the timeline of implementing and stabilizing FLIP-547 is relatively long (PCMIIW), so this feature still makes sense. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
