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

[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)