[jira] [Created] (FLINK-18402) NullPointerException in org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:96)

[Shang Yuanchun (Jira)]

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)