[jira] [Created] (FLINK-15634) disableAutoGeneratedUIDs fails with coGroup and join

[Shang Yuanchun (Jira)]

Jürgen Kreileder created FLINK-15634:
----------------------------------------

             Summary: 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


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)