William Cheng created FLINK-14910: ------------------------------------- Summary: disableAutoGeneratedUIDs fails on keyBy Key: FLINK-14910 URL: https://issues.apache.org/jira/browse/FLINK-14910 Project: Flink Issue Type: Bug Reporter: William Cheng
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. -- This message was sent by Atlassian Jira (v8.3.4#803005)