Sihua Zhou created FLINK-7180:
---------------------------------
Summary: CoGroupStream perform checkpoint failed
Key: FLINK-7180
URL: https://issues.apache.org/jira/browse/FLINK-7180
Project: Flink
Issue Type: Bug
Components: DataStream API
Affects Versions: 1.3.1
Reporter: Sihua Zhou
Assignee: Sihua Zhou
When using the CoGroup api and enable the checkpoint, Job will failed when
perform checkpoint, e.g:
{code:java}
input1.coGroup(input2)
.where(new KeySelector<String, String>() {
@Override
public String getKey(String value) throws Exception {
return value;
}
})
.equalTo(new KeySelector<String, String>() {
@Override
public String getKey(String value) throws Exception {
return value;
}
})
.window(SlothJoinWindow.create())
.trigger(new SlothWindowTrigger(0))
.apply(new CoGroupFunction<String, String, String>() {
@Override
public void coGroup(Iterable<String> first,
Iterable<String> second, Collector<String> out) throws Exception {
String outputStr = "first:" + first + " , second:" +
second;
System.out.println(outputStr);
out.collect(outputStr);
}
})
.keyBy(new KeySelector<String, String>() {
@Override
public String getKey(String value) throws Exception {
return value;
}
})
.print();
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
