xintongsong commented on PR #138: URL: https://github.com/apache/flink-agents/pull/138#issuecomment-3314996789
Since the Kafka-store is not yet implemented, I have a few questions about its expected behavior. 1. When calling `put()` with an `ActionState` whose `generatedActionTask` is not `null` (meaning the action is not finished), the action state will not be flushed to the external Kafka and will be kept in memory, until another `put()` that changes the `generatedActionTask` to `null` (meaning the action is finished). Am I understanding correctly? 2. When we say `get()` will ignore states after a not-found sequence number, does it include new states written after the not-founding `get()`? E.g., we put `s1, s2` into the store, and then try to get `s1` with a mismatched action or seq-num, then its expected that both `s1, s2` will not be used. But what if we then put a `s3` into the store? -- 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]
