pnowojski commented on PR #26051: URL: https://github.com/apache/flink/pull/26051#issuecomment-2612061387
Thanks for your answers @Zakelly and @xuyangzhong! One more thing. At the moment I have only sync implementation of the append-only deduplicate operator. I guess there is no harm if this is merged as is, so that the synchronous version will be used despite `isAsyncStateEnabled()` being enabled, right? The code will remain correct? And I can provide async version in a separate PR/ticket? (relevant code is in the `StreamExecDeduplicate`). -- 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]
