Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41531514
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ *
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41523437
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellLocalStartupITCase.scala
---
@@ -0,0 +1,60 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41523760
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41523825
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948785#comment-14948785
]
ASF GitHub Bot commented on FLINK-1966:
---
Github user chiwanpark commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948786#comment-14948786
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948787#comment-14948787
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41525735
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
---
@@ -225,8 +223,50 @@ class
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948807#comment-14948807
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948813#comment-14948813
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41526411
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41526551
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948814#comment-14948814
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user ktzoumas commented on the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41526594
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed to the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1234#issuecomment-146578211
Ah, I see. Then the change looks good, correct?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41527930
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41528000
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948845#comment-14948845
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41528652
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-1129.
---
Resolution: Fixed
This is resolved by the new JobManager web interface.
> The Plan
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948868#comment-14948868
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user mbalassi commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948910#comment-14948910
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1242#issuecomment-146599121
This is pretty straightforward.
If no one has any reservations against removing the old API (which has been
reworked into the new API) I would go ahead. The
[
https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948929#comment-14948929
]
ASF GitHub Bot commented on FLINK-2780:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948954#comment-14948954
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948908#comment-14948908
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41532867
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41532972
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948915#comment-14948915
]
ASF GitHub Bot commented on FLINK-2808:
---
Github user gyfora commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948947#comment-14948947
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948946#comment-14948946
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41535673
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948945#comment-14948945
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41535719
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licensed
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1153#issuecomment-146610846
I've addressed your points. Thanks for taking the time to review again. I
had to revert the check point ID counter removal. Sorry for the confusion. If
we don't find
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948966#comment-14948966
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41536137
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -0,0 +1,380 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948988#comment-14948988
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user ktzoumas commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948953#comment-14948953
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-146624231
Added docs for chaining and resource groups
---
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
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1239#issuecomment-146594656
As for the context, I did not mean to add it to the Checkpointed interface
but to the state backend method calls.
Other simpler solution for now would be to
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41535485
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -0,0 +1,423 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948940#comment-14948940
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948952#comment-14948952
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41536142
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -0,0 +1,380 @@
+/*
+ * Licensed to
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41536249
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -0,0 +1,380 @@
+/*
+ * Licensed to
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1242#issuecomment-146608549
+1 to remove. I find it confusing as well.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948959#comment-14948959
]
ASF GitHub Bot commented on FLINK-2780:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1153#issuecomment-146639217
Till found another issue in one of is Travis runs, which has been addressed
in e54a86c.
This is now rebased on the current master.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949063#comment-14949063
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949480#comment-14949480
]
Saumitra Shahapure commented on FLINK-2714:
---
I have a question. In EnumTrianglesOpt.java
[
https://issues.apache.org/jira/browse/FLINK-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Saumitra Shahapure updated FLINK-2714:
--
Comment: was deleted
(was: I have a question. In EnumTrianglesOpt.java
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949767#comment-14949767
]
ASF GitHub Bot commented on FLINK-2731:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1242#issuecomment-146738873
+1 to get rid of the old API asap.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949838#comment-14949838
]
Robert Metzger commented on FLINK-2611:
---
Btw: I don't think that this issue is critical for the 0.10
[
https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949785#comment-14949785
]
Robert Metzger commented on FLINK-2611:
---
I also saw this issue from time to time.
Let me see
[
https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949784#comment-14949784
]
ASF GitHub Bot commented on FLINK-2780:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949789#comment-14949789
]
Robert Metzger commented on FLINK-2716:
---
Correct me if I'm wrong (I don't know that part of the code
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1233#issuecomment-146752849
IMO this can be merged as it works as expected in non-yarn mode. And the
number of changes to be made are minimal when you finally merge your PR.
I can
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949873#comment-14949873
]
ASF GitHub Bot commented on FLINK-2731:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949776#comment-14949776
]
ASF GitHub Bot commented on FLINK-2793:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1202#issuecomment-146737613
Are there any blockers to this PR. Otherwise, I'd like to have it merged
rather soon.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-2831:
---
I'm reopening the issue since the test deadlocked? recently on master:
[
https://issues.apache.org/jira/browse/FLINK-2725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949843#comment-14949843
]
ASF GitHub Bot commented on FLINK-2725:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949806#comment-14949806
]
Robert Metzger commented on FLINK-2611:
---
Steps to reproduce:
{{./bin/yarn-session -n 1}}
... wait
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1233#issuecomment-146737214
@sachingoel0101: my pull request
(https://github.com/apache/flink/pull/1222) is actually based on @uce's PR
(https://github.com/apache/flink/pull/1202). I'm not sure
[
https://issues.apache.org/jira/browse/FLINK-2725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14949841#comment-14949841
]
ASF GitHub Bot commented on FLINK-2725:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1191#discussion_r41595057
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java
---
@@ -51,7 +51,18 @@
public class ValueTypeInfo extends
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1191#discussion_r41595115
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/aggregation/SumAggregationFunction.java
---
@@ -113,11 +182,32 @@ public Long getAggregate() {
201 - 269 of 269 matches
Mail list logo
