You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/19 07:48:00 UTC
[jira] [Closed] (FLINK-10916) Include duplicated user-specified uid
into error message
[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-10916.
------------------------------------
Resolution: Fixed
Fix Version/s: 1.7.0
1.6.3
1.5.6
master: 8eb6cfff9dfcc5a819c03b67db7ce879945341f0
1.7: 3c1f14ebecf74e7e014a11c8f790061dd0a79b2d
1.6: 73f0fd2b4515d2027ba2843c0c61800257bd2699
1.5: b72c8f2e6ae7eed42c5725848516286769e61854
> 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: DataStream API
> Reporter: Kirill Mikheev
> Priority: Trivial
> Labels: easyfix, newbie, pull-request-available
> 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
(v7.6.3#76005)