Hi Weijie, Regarding FLIP-410, I have the following questions:
Q1. In the "Configuration" section, it is mentioned that configurations can be set continuously using the withXXX methods. Are these configuration options the same as those provided by DataStream V1, or might there be different options compared to V1? Q2. The FLIP describes the interface for handling processing timers (ProcessingTimeManager), but it does not mention how to delete or update an existing timer. V1 API provides TimeService that could delete a timer. Does this mean that once a timer is registered, it cannot be changed? I hope to receive answers when you have time, thank you! Best, Wencong Liu At 2023-12-26 14:46:24, "weijie guo" <guoweijieres...@gmail.com> wrote: >Hi devs, > > >I'd like to start a discussion about FLIP-410: Config, Context and >Processing Timer Service of DataStream API V2 [1]. This is the second >sub-FLIP of DataStream API V2. > > >In FLIP-409 [2], we have defined the most basic primitive of >DataStream V2. On this basis, this FLIP will further answer several >important questions closely related to it: > > 1. > How to configure the processing over the datastreams, such as >setting the parallelism. > 2. > How to get access to the runtime contextual information and >services from inside the process functions. > 3. How to work with processing-time timers. > >You can find more details in this FLIP. Its relationship with other >sub-FLIPs can be found in the umbrella FLIP >[3]. > > >Looking forward to hearing from you, thanks! > > >Best regards, > >Weijie > > >[1] >https://cwiki.apache.org/confluence/display/FLINK/FLIP-410%3A++Config%2C+Context+and+Processing+Timer+Service+of+DataStream+API+V2 > >[2] >https://cwiki.apache.org/confluence/display/FLINK/FLIP-409%3A+DataStream+V2+Building+Blocks%3A+DataStream%2C+Partitioning+and+ProcessFunction > >[3] >https://cwiki.apache.org/confluence/display/FLINK/FLIP-408%3A+%5BUmbrella%5D+Introduce+DataStream+API+V2
