[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
William Cheng updated FLINK-14910: ---------------------------------- Description: There doesn't seem to be a way to add a UID to the Partition operator created by KeyBy, causing `disableAutoGeneratedUIDs` to fail. Here's a simple test case that will reproduce the issue: {noformat} @Test public void testFailedUID() throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.getConfig().disableAutoGeneratedUIDs(); DataStream<String> data = env.fromCollection(Arrays.asList("1", "2", "3")).uid("source-uid"); data.keyBy(i -> i) .map(i -> i).uid("map-uid"); env.execute(); }{noformat} {noformat} testFailedUID(twitch.creatoranalytics.sessions.StreamingJobTest) Time elapsed: 0.008 sec <<< ERROR! java.lang.IllegalStateException: Auto generated UIDs have been disabled but no UID or hash has been assigned to operator Partition {noformat} This passes if the keyBy is removed. was: There doesn't seem to be a way to add a UID to the Partition operator created by KeyBy, causing `disableAutoGeneratedUIDs` to fail. Here's a simple test case that will reproduce the issue: {noformat} @Test public void testFailedUID() throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.getConfig().disableAutoGeneratedUIDs(); DataStream<String> data = env.fromCollection(Arrays.asList("1", "2", "3")).uid("source-uid"); data.keyBy(i -> i) .map(i -> i).uid("map-uid"); env.execute(); }{noformat} This passes if the keyBy is removed. > disableAutoGeneratedUIDs fails on keyBy > --------------------------------------- > > Key: FLINK-14910 > URL: https://issues.apache.org/jira/browse/FLINK-14910 > Project: Flink > Issue Type: Bug > Reporter: William Cheng > Priority: Major > > There doesn't seem to be a way to add a UID to the Partition operator created > by KeyBy, causing `disableAutoGeneratedUIDs` to fail. > > Here's a simple test case that will reproduce the issue: > {noformat} > @Test > public void testFailedUID() throws Exception { > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getConfig().disableAutoGeneratedUIDs(); > DataStream<String> data = env.fromCollection(Arrays.asList("1", "2", > "3")).uid("source-uid"); > data.keyBy(i -> i) > .map(i -> i).uid("map-uid"); > env.execute(); > }{noformat} > {noformat} > testFailedUID(twitch.creatoranalytics.sessions.StreamingJobTest) Time > elapsed: 0.008 sec <<< ERROR! > java.lang.IllegalStateException: Auto generated UIDs have been disabled but > no UID or hash has been assigned to operator Partition > {noformat} > > This passes if the keyBy is removed. -- This message was sent by Atlassian Jira (v8.3.4#803005)