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

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16087062#comment-16087062 ] 

Aljoscha Krettek commented on FLINK-7180:
-----------------------------------------

[~sihuazhou] Could you please attach a stack trace or some output that shows how the job fails?

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