Kavishankarks opened a new pull request, #63:
URL: https://github.com/apache/flink-agents/pull/63
This change introduces enhanced JSON serialization support for Row objects
within the Event class in the Flink Agents module. Specifically:
Adds a custom row_serializer() function to convert PyFlink Row instances
into serializable dictionaries.
Implements model_dump_json() override and _serialize_with_row_support() to
gracefully handle Row serialization across all events.
Adds utility methods to detect serialization issues exclusively caused by
Row objects, preventing false-positive validation errors.
Includes test coverage for both valid and invalid serialization cases
involving Row and non-serializable types.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
