You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jürgen Kreileder (Jira)" <ji...@apache.org> on 2020/01/17 10:53:00 UTC
[jira] [Created] (FLINK-15634) disableAutoGeneratedUIDs fails with
coGroup and join
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)