wenjin272 commented on issue #872: URL: https://github.com/apache/flink-agents/issues/872#issuecomment-4888853225
Thank you for your exploration of this issue @weiqingy. In fact, I am reconsidering whether JSON serialization is appropriate for the `MemoryUpdate` field when serialized alongside `ActionState`. Currently, deserialization risks losing type information for types such as bytes or Long. Since `MemoryUpdate` values are stored as generic Objects, user-defined POJOs may face similar issues. `MemoryUpdate` stores data written to Flink State. To ensure full semantic consistency after restoring from `ActionState`, I prefer using Flink’s native State Serializer directly. If that proves inconvenient, Kryo serialization would also be acceptable. The key objective is to switch from JSON-based serde to binary-based serde. For the `Event` field, however, cross-language requirements and Event-Log needs mandate JSON serializability. Therefore, retaining JSON-based serialization for this field maintains readability and ensures no loss of fidelity. 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]
