da-daken commented on issue #1016: URL: https://github.com/apache/flink-agents/issues/1016#issuecomment-5535138330
@weiqingy @wenjin272 Before starting this work, I think we can first align on the recovery model. I believe that for recovery, the function only needs to maintain a unique ID. Currently, matching is done using both the `ID` and the `argsDigest`. The `argsDigest `is essentially an enhancement added by the system to account for the possibility of user operation errors. However, in practice, even if the parameters and the method remain the same, if the data source of that method has changed, it should logically be re-run. But currently, both the Python side and the Java side can still incorrectly recover in such cases. Fundamentally, we need to maintain a unique ID for all persistent methods within a single action for matching purposes. WDYT? -- 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]
