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

Posted to dev@flink.apache.org by "xuhuang (Jira)" <ji...@apache.org> on 2025/02/10 07:36:00 UTC

[jira] [Created] (FLINK-37290) Introduce endPartition to DataStream V2 ProcessFunction

xuhuang created FLINK-37290:
-------------------------------

             Summary: Introduce endPartition to DataStream V2 ProcessFunction
                 Key: FLINK-37290
                 URL: https://issues.apache.org/jira/browse/FLINK-37290
             Project: Flink
          Issue Type: New Feature
          Components: API / DataStream
            Reporter: xuhuang


The _ProcessFunction_ requires a method to indicate that the current processing partition has ended. This is useful in batch scenarios for outputting results and clearing state.



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