wenjin272 commented on PR #45: URL: https://github.com/apache/flink-agents/pull/45#issuecomment-3017490278
> I'm currently working on implementing a few Flink operators based on this PR to handle workflow processing #26 , but I encountered a non-serializable exception with _WorkflowPlan_. <img alt="image" width="1605" src="https://private-user-images.githubusercontent.com/130116763/460215965-c747d395-5d5a-4311-a197-1565eb089bc3.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NTEyNDgyNTcsIm5iZiI6MTc1MTI0Nzk1NywicGF0aCI6Ii8xMzAxMTY3NjMvNDYwMjE1OTY1LWM3NDdkMzk1LTVkNWEtNDMxMS1hMTk3LTE1NjVlYjA4OWJjMy5wbmc_WC1BbXotQWxnb3JpdGhtPUFXUzQtSE1BQy1TSEEyNTYmWC1BbXotQ3JlZGVudGlhbD1BS0lBVkNPRFlMU0E1M1BRSzRaQSUyRjIwMjUwNjMwJTJGdXMtZWFzdC0xJTJGczMlMkZhd3M0X3JlcXVlc3QmWC1BbXotRGF0ZT0yMDI1MDYzMFQwMTQ1NTdaJlgtQW16LUV4cGlyZXM9MzAwJlgtQW16LVNpZ25hdHVyZT0zN2FkMTdiYTJhZWM4MjJlMGE4MjhhN2NhZDFiNTY4NDRiZWIwZDA4YWQ1NWNjOWFiODFmYzJlMjQ4ZTc4NjU3JlgtQW16LVNpZ25lZEhlYWRlcnM9aG9zdCJ9.3jgAGEXjAAn5-IwA0uCHCRRAzyE77NKJLtX3pl54 r9s"> > > I resolved this by: > > 1. Making _WorkflowPlan_ implement the _Serializable_ interface. > 2. Overriding the _writeObject_ and _readObject_ methods using _WorkflowPlanJsonSerializer_ and _WorkflowPlanJsonDeserializer_. > > You might want to consider incorporating this fix into this PR as well 😊 Could we store the plan json rather than plan object? -- 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]
