Xuannan Su created FLINK-33890:
----------------------------------

             Summary: Determine the initial status before receiving the first 
RecordAttributes 
                 Key: FLINK-33890
                 URL: https://issues.apache.org/jira/browse/FLINK-33890
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Task
            Reporter: Xuannan Su


Currently, all the operators are initialized with non-backlog mode. Ideally, we 
should determine the initial status before receiving the first 
{{RecordAttributes}} so that we don't have to initialize the operator in 
non-backlog mode and immediately switch to backlog mode before processing any 
records.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to