Jiayi Liao created FLINK-14646: ---------------------------------- Summary: Check 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.9.0 Reporter: Jiayi Liao
We should check 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)