Hello everyone, I have a list with bunch of elements and I need create a Row.of() based on the whole elements. I try to apply a lambda function for this purpose as:
mylist.forEach(n->out.collect(Row.of(n))); but I got the exception below: org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next operator How properly should I feed the Row based on the list elements? thanks so much AU
