[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann updated FLINK-14646: ---------------------------------- Priority: Minor (was: Major) > 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 > Assignee: Jiayi Liao > Priority: Minor > Labels: pull-request-available > Fix For: 1.10.0, 1.8.3, 1.9.2 > > Time Spent: 10m > Remaining Estimate: 0h > > 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)