You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Andres Angel <in...@gmail.com> on 2019/07/26 03:14:07 UTC

Assign a Row.of(ListsElements) exception

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

Re: Assign a Row.of(ListsElements) exception

Posted by Caizhi Weng <ts...@gmail.com>.

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 <in...@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
>