Zoi Kaoudi

I think you missed the mapping from the KafkaSourceOperator which is a platform-agnostic Wayang operator to its Java-specific implementation. See, for example, here for the FlatMap Operator: https://github.com/apache/incubator-wayang/blob/main/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/FlatMapMapping.java Then this...

Hmmm that's interesting but at least we move forward :) I think because you added the following without adding these keys in the properties files, it throws the execption: @Override...

That's awesome! The best way is to provide the keys and add the cost function in the properties file. Now there are some conflicts in some files.. I will check...

@2pk03 for some reason there are conflicts which must be resolved before merging.