zhoupeijie created FLINK-18402:
----------------------------------
Summary: NullPointerException in
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:96)
Key: FLINK-18402
URL: https://issues.apache.org/jira/browse/FLINK-18402
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.10.0
Environment: flink 1.10
Reporter: zhoupeijie
I use array as follows:
{code:java}
DataStream<Tuple2<Boolean, CompanyBrandEntity>> ds =
tEnv.toRetractStream(companyBrandSource, CompanyBrandEntity.class);
SingleOutputStreamOperator<Object[]> middleData = ds.map(new
RuleMapFunction(ruleList))
.filter(Objects::nonNull);
{code}
and I get this error:
{code:java}
java.lang.NullPointerException
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:96)
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:37)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:639)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:616)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:596)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:708)
at
org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:41)
{code}
{color:#111f2c}then I change the SingleOutputStreamOperator<Object[]> to
SingleOutputStreamOperator<Ouput>,it begins to run correctly.{color}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
