Daniel Bosnic Hill created FLINK-25285:
------------------------------------------
Summary: CoGroupedStreams has inner Maps without easy ways to set
uid
Key: FLINK-25285
URL: https://issues.apache.org/jira/browse/FLINK-25285
Project: Flink
Issue Type: Bug
Components: API / Core
Affects Versions: 1.14.0
Reporter: Daniel Bosnic Hill
I tried to use CoGroupedStreams w/ disableAutoGeneratedUIDs. CoGroupedStreams
creates two map operators without the ability to set uids on them. These
appear as "Map" in my operator graph. I noticed that the
CoGroupedStreams.apply function has two map calls without setting uids. If I
try to run with disableAutoGeneratedUIDs, I get the following error
"java.lang.IllegalStateException: Auto generated UIDs have been disabled but no
UID or hash has been assigned to operator Map".
>From Flink user group email thread "CoGroupedStreams and
>disableAutoGeneratedUIDs".
https://github.com/apache/flink/blob/release-1.14/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java#L379
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
