weiqingy commented on issue #836: URL: https://github.com/apache/flink-agents/issues/836#issuecomment-4700835738
When this end-to-end checkpoint-recovery harness lands, it would be a good home for a permanent `bytes` round-trip assertion: `memory.set(k, b"...")` in Python → checkpoint → TaskManager restart → `memory.get(k)` equals the original. #846 admits exact Python `bytes` into the memory value contract (verified via Pemja source + a local embedded-interpreter probe that materializes `bytes` as a native Java `byte[]`), but a true restart round-trip can't run on the MiniCluster, so an e2e assertion here would close the loop. -- 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]
