[FLINK-15634] disableAutoGeneratedUIDs fails with coGroup and join

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Jürgen Kreileder
• Created: 17/Jan/20 10:52
• Updated: 19/Nov/21 22:38

Description

coGroup/join seems to generate two Map operators for which you can't set the UID. 

Here's a test case:

@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();
}