Hi, wow, oh that's indeed a nice solution.
Your version still threw some errors: > Caused by: org.apache.flink.api.common.InvalidProgramException: Object > factorytest.Config$1@5143c662 not serializable > Caused by: java.io.NotSerializableException: factorytest.factory.PearFactory I fixed this by adding "implements java.io.Serializable" to the IDataFactory (and all other interfaces right away) - I hope that won't backfire in the future. Anyway, the problem seems solved. Yay and thank you! Kind regards, Sebastian
