[jira] [Created] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

[Shang Yuanchun (Jira)]

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)