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)