[jira] [Closed] (FLINK-7180) CoGroupStream perform checkpoint failed

["Sihua Zhou (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sihua Zhou closed FLINK-7180.
-----------------------------
    Resolution: Resolved

> 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
>            Priority: Blocker
>             Fix For: 1.3.2
>
>
> When using the CoGroup api and enable the checkpoint, Job will failed when performing 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)