[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152586 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943466#comment-14943466 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on the p

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943464#comment-14943464 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152418 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943467#comment-14943467 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-145554976 Great piece of work @uce :-) I've gone through the code and added some comments. The main points are * the exception handling in `ZooKeeperSubmittedJobGra

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943462#comment-14943462 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943458#comment-14943458 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943460#comment-14943460 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943459#comment-14943459 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152294 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152368 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152286 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionService.java --- @@ -67,4 +67,20 @@ * @return true if the as

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152317 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943457#comment-14943457 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152243 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152128 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943454#comment-14943454 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152087 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152116 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateForTask.java --- @@ -48,9 +55,9 @@ private final int subtask;

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943449#comment-14943449 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943455#comment-14943455 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152148 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943453#comment-14943453 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943450#comment-14943450 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152092 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/StandaloneSubmittedJobGraphs.java --- @@ -0,0 +1,65 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152041 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -110,61 +120,68 @@ public CheckpointCoo

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41152054 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -178,9 +195,9 @@ public void run() { * After

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943447#comment-14943447 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41151947 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943446#comment-14943446 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943444#comment-14943444 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41151770 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/SubmittedJobGraphs.java --- @@ -0,0 +1,92 @@ +/* + * Licensed to the Apache Sof

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41151872 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache So

[jira] [Closed] (FLINK-2807) Add javadocs/comments to new windowing mechanics

2015-10-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2807. --- Resolution: Fixed Added in https://github.com/apache/flink/commit/62df0a0349b276d4a5b7d9954d2

[GitHub] flink pull request: Stream API Refactoring

2015-10-05 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1215 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943438#comment-14943438 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41151337 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943434#comment-14943434 ] Maximilian Michels commented on FLINK-2236: --- Note that the subtask has already b

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943423#comment-14943423 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943432#comment-14943432 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41150514 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionService.java --- @@ -67,4 +67,20 @@ * @return true

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41149990 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java --- @@ -0,0 +1,130 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41149926 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943421#comment-14943421 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943422#comment-14943422 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145546618 1. I don't know if someone else is working on this, but this way we can provide a log and out file the way it is displayed, say on travis. Updated in real time. A

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41149494 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * License

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943412#comment-14943412 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943414#comment-14943414 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41149560 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * License

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943403#comment-14943403 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41147873 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java --- @@ -0,0 +1,130 @@ +/* + * Licens

[jira] [Commented] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943395#comment-14943395 ] ASF GitHub Bot commented on FLINK-2815: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-2815] [REFACTOR] Remove Pact from class...

2015-10-05 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1218#issuecomment-145537573 Makes sense, will make that update --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943394#comment-14943394 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41146895 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41145818 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoints.java --- @@ -0,0 +1,69 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943393#comment-14943393 ] ASF GitHub Bot commented on FLINK-2811: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145536979 Two comments: 1) In the old web frontend, we showed the log and out files raw in a new tab. I think that was good, it allows to download/save the files witho

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41146553 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943392#comment-14943392 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943391#comment-14943391 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41146216 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943389#comment-14943389 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41146020 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943387#comment-14943387 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943385#comment-14943385 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41145710 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/SubmittedJobGraphs.java --- @@ -0,0 +1,92 @@ +/* + * Licensed to the A

[GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi...

2015-10-05 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1219#issuecomment-145532006 Updated as per @StephanEwen's comments. Here's another screenshot: ![capture](https://cloud.githubusercontent.com/assets/8874261/10281934/7c80cce4-6b95-11e5-88

[jira] [Commented] (FLINK-2811) Add page with configuration overview

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943374#comment-14943374 ] ASF GitHub Bot commented on FLINK-2811: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943375#comment-14943375 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41144758 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Resolved] (FLINK-2482) Document sreaming processing guarantees

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2482. --- Resolution: Fixed Assignee: Stephan Ewen > Document sreaming processing guarante

[jira] [Resolved] (FLINK-2787) Prevent explicit use of RemoteEnvironment when running a job through the command line

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2787. --- Resolution: Fixed > Prevent explicit use of RemoteEnvironment when running a job throu

[jira] [Updated] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2263: -- Fix Version/s: 0.10 > ExecutionGraph uses Thread.sleep to delay execution retries >

[jira] [Assigned] (FLINK-1610) Java docs do not build

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-1610: - Assignee: Maximilian Michels > Java docs do not build > -- >

[jira] [Updated] (FLINK-1610) Java docs do not build

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-1610: -- Affects Version/s: 0.10 > Java docs do not build > -- > >

[GitHub] flink pull request: [FLINK-1610] fix building of java doc for Java...

2015-10-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1225#issuecomment-145529038 The JavaDoc can be built using ``` mvn javadoc:aggregate -Pdocs-and-source -DadditionalJOption="-Xdoclint:none" ``` The `-Xdoclint:none` is still require

[jira] [Commented] (FLINK-1610) Java docs do not build

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943363#comment-14943363 ] ASF GitHub Bot commented on FLINK-1610: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-2740) Create data consumer for Apache NiFi

2015-10-05 Thread Bryan Bende (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943351#comment-14943351 ] Bryan Bende commented on FLINK-2740: Thanks for merging! Looking forward to seeing NiF

[jira] [Updated] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library

2015-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2714: - Assignee: Saumitra Shahapure > Port the Flink DataSet Triangle Count example to the Gelly library

[jira] [Commented] (FLINK-1610) Java docs do not build

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943346#comment-14943346 ] ASF GitHub Bot commented on FLINK-1610: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-1610] fix building of java doc for Java...

2015-10-05 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1225 [FLINK-1610] fix building of java doc for Java 8 You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-1610 Alternatively you can review

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943338#comment-14943338 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41140867 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java --- @@ -19,29 +19,28 @@ package org.apache.flin

[jira] [Commented] (FLINK-1675) Rework Accumulators

2015-10-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943311#comment-14943311 ] Maximilian Michels commented on FLINK-1675: --- Thanks for the pointer [~uce]. I'd

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41138250 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943312#comment-14943312 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943310#comment-14943310 ] ASF GitHub Bot commented on FLINK-2354: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41138121 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943305#comment-14943305 ] ASF GitHub Bot commented on FLINK-2797: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs...

2015-10-05 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1214#issuecomment-145513084 That sounds good. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-1675) Rework Accumulators

2015-10-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943301#comment-14943301 ] Ufuk Celebi commented on FLINK-1675: Max, there was this PR which addressed (5): http

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943297#comment-14943297 ] ASF GitHub Bot commented on FLINK-2767: --- Github user nikste commented on the pull re

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-05 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145510215 For me it says: ~~~bash Failed to created JLineReader: java.lang.NoClassDefFoundError: jline/console/completer/Completer Falling back to SimpleReader. ~~~

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943295#comment-14943295 ] ASF GitHub Bot commented on FLINK-2767: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-05 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145509803 Oh, I'll investigate it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

2015-10-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14943291#comment-14943291 ] ASF GitHub Bot commented on FLINK-2767: --- Github user nikste commented on the pull re

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-05 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-145509252 Code looks fine. However, I noticed if I compile the code (for scala version 2.11), and start up the scala shell manually (./start-scala-shell.sh), the autocomplete funct

<    1   2   3   4   >