[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu updated FLINK-10916: ------------------------------- Labels: easyfix pull-request-available starter (was: easyfix newbie pull-request-available) > Include duplicated user-specified uid into error message > -------------------------------------------------------- > > Key: FLINK-10916 > URL: https://issues.apache.org/jira/browse/FLINK-10916 > Project: Flink > Issue Type: Improvement > Components: API / DataStream > Reporter: Kirill Mikheev > Priority: Minor > Labels: easyfix, pull-request-available, starter > Fix For: 1.5.6, 1.6.3, 1.7.0 > > > If user provides non-unique uid for a stream, error message does not give a > clue where does the error reside in client code. Including user-provided uid > into error message should narrow the search area. > In 1.6.2 we see the message that was introduced in 1.2.0: > {noformat} > java.lang.IllegalArgumentException: Hash collision on user-specified ID. Most > likely cause is a non-unique ID. Please check that all IDs specified via > uid(String) are unique. at > org.apache.flink.streaming.api.graph.StreamGraphHasherV2.generateNodeHash(StreamGraphHasherV2.java:180) > at > org.apache.flink.streaming.api.graph.StreamGraphHasherV2.traverseStreamGraphAndGenerateHashes(StreamGraphHasherV2.java:112) > at > org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:134) > at <rest of stack>. > {noformat} -- This message was sent by Atlassian Jira (v8.20.10#820010)