Assign a Row.of(ListsElements) exception

[Andres Angel]

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

[Caizhi Weng]

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 <[hidden email]> 于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