[jira] [Updated] (FLINK-14910) DisableAutoGeneratedUIDs fails on keyBy

["Hequn Cheng (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hequn Cheng updated FLINK-14910:
--------------------------------
    Summary: DisableAutoGeneratedUIDs fails on keyBy  (was: disableAutoGeneratedUIDs fails on keyBy)

> DisableAutoGeneratedUIDs fails on keyBy
> ---------------------------------------
>
>                 Key: FLINK-14910
>                 URL: https://issues.apache.org/jira/browse/FLINK-14910
>             Project: Flink
>          Issue Type: Bug
>          Components: API / DataStream
>    Affects Versions: 1.9.0
>            Reporter: William Cheng
>            Assignee: Dawid Wysakowicz
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.9.2, 1.10.0
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> 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)