Hi Andres, This exception is often caused by other exceptions. Please post your full stack trace here so we can diagnose the problem. Thanks.
Andres Angel <ingenieroandresan...@gmail.com> 于2019年7月26日周五 上午11:14写道： > 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 >
