[ https://issues.apache.org/jira/browse/FLINK-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018636#comment-17018636 ]
Kenneth William Krugler commented on FLINK-15634: ------------------------------------------------- Is this a duplicate of https://issues.apache.org/jira/browse/FLINK-14910? > disableAutoGeneratedUIDs fails with coGroup and join > ---------------------------------------------------- > > Key: FLINK-15634 > URL: https://issues.apache.org/jira/browse/FLINK-15634 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Affects Versions: 1.10.0 > Reporter: Jürgen Kreileder > Priority: Major > > coGroup/join seems to generate two Map operators for which you can't set the > UID. > Here's a test case: > {code:java} > @Test > public void testDisablingAutoUidsWorksWithCoGroup() throws Exception { > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.getConfig().disableAutoGeneratedUIDs(); > env > .addSource(new > NoOpSourceFunction()).setUidHash("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa") > .coGroup(env.addSource(new > NoOpSourceFunction()).setUidHash("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb")) > .where(o -> o).equalTo(o -> o) > .window(TumblingEventTimeWindows.of(Time.days(1))) > .with(new CoGroupFunction<String, String, Object>() { > @Override > public void coGroup(Iterable<String> first, Iterable<String> second, > Collector<Object> out) throws Exception { > } > }).setUidHash("cccccccccccccccccccccccccccccccc") > .addSink(new > DiscardingSink<>()).setUidHash("dddddddddddddddddddddddddddddddd"); > env.execute(); > } > {code} > -- This message was sent by Atlassian Jira (v8.3.4#803005)