[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann updated FLINK-14646: ---------------------------------- Fix Version/s: 1.9.2 1.8.3 1.10.0 > Check non-null for key in KeyGroupStreamPartitioner > --------------------------------------------------- > > Key: FLINK-14646 > URL: https://issues.apache.org/jira/browse/FLINK-14646 > Project: Flink > Issue Type: Improvement > Components: Runtime / State Backends > Affects Versions: 1.8.2, 1.10.0, 1.9.1 > Reporter: Jiayi Liao > Priority: Major > Fix For: 1.10.0, 1.8.3, 1.9.2 > > > We should check non-null for {{key}} in {{selectChannel}} function in > {{KeyGroupStreamPartitioner}} because {{KeyGroupRangeAssignment}} does not > allow null key for assignment. And if we produce a null key in > {{KeyGroupStreamPartitioner}}, the exception is not clear enough. > {code:java} > Caused by: java.lang.NullPointerException > at > org.apache.flink.runtime.state.KeyGroupRangeAssignment.assignToKeyGroup(KeyGroupRangeAssignment.java:60) > at > org.apache.flink.runtime.state.KeyGroupRangeAssignment.assignKeyToParallelOperator(KeyGroupRangeAssignment.java:49) > at > org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.selectChannel(KeyGroupStreamPartitioner.java:58) > at > org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.selectChannel(KeyGroupStreamPartitioner.java:32) > at > org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:120) > at > org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110) > ... 9 more > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)