Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41503746
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -68,38 +94,62 @@ object FlinkShell {
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41503700
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -68,38 +94,62 @@ object FlinkShell {
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41503724
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -68,38 +94,62 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948532#comment-14948532
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948541#comment-14948541
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark 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_r41504146
--- Diff: docs/apis/scala_shell.md ---
@@ -30,15 +30,16 @@ Flink and setting up a cluster please refer to
To use the shell with an integrated Flink
[
https://issues.apache.org/jira/browse/FLINK-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948416#comment-14948416
]
Chiwan Park commented on FLINK-2750:
Does this bug still exist? {{mvn clean install
[
https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948439#comment-14948439
]
ASF GitHub Bot commented on FLINK-2808:
---
Github user gyfora commented on the pull request:
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-146507345
Hey @chiwanpark !
I've rebased this to the current master. Would be nice if this can be
merged soon if there are no further comments on this PR!
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948502#comment-14948502
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-146509420
@twalthr Doesn't seem to compile :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948584#comment-14948584
]
ASF GitHub Bot commented on FLINK-2790:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948391#comment-14948391
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pull request:
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1186#discussion_r41497773
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala
---
@@ -124,6 +121,52 @@ class
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948457#comment-14948457
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull request:
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41503504
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41503540
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948524#comment-14948524
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark 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_r41503568
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948527#comment-14948527
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948525#comment-14948525
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark 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_r41503496
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948543#comment-14948543
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark 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_r41504295
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellLocalStartupITCase.scala
---
@@ -0,0 +1,61 @@
+/*
+
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41504243
--- Diff: docs/apis/scala_shell.md ---
@@ -30,15 +30,16 @@ Flink and setting up a cluster please refer to
To use the shell with an integrated Flink
Greg Hogan created FLINK-2834:
-
Summary: Global round-robin for temporary directories
Key: FLINK-2834
URL: https://issues.apache.org/jira/browse/FLINK-2834
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948699#comment-14948699
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948704#comment-14948704
]
Paris Carbone commented on FLINK-2836:
--
Maybe the Flink->Samoa Topology integration will help you
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948691#comment-14948691
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user mxm commented on the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/593
---
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
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-146553988
Merged. Congrats :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1789.
-
Resolution: Implemented
Fix Version/s: 0.10
> Allow adding of URLs to the usercode
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-146560991
@nikste Sorry for bothering you, but there are still some style issues.
Looks good to merge except the issues.
---
If your project is set up for it, you can reply
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-146542207
Thanks for this big update, guys!
Some comments:
* Explanation of operator chaining and options are missing.
* Collection Data Sources: The
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948690#comment-14948690
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948741#comment-14948741
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
Matthias J. Sax created FLINK-2835:
--
Summary: Update Documenation for new Streaming API
Key: FLINK-2835
URL: https://issues.apache.org/jira/browse/FLINK-2835
Project: Flink
Issue Type: Task
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41518056
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -67,39 +93,62 @@ object FlinkShell {
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41518604
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
---
@@ -34,16 +34,16 @@ class FlinkILoop(
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948723#comment-14948723
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948726#comment-14948726
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark 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_r41519871
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
---
@@ -225,8 +223,50 @@ class
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41519895
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellLocalStartupITCase.scala
---
@@ -0,0 +1,60 @@
+/*
+
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-146533038
Okay, if there is no objection and the travis passes, I'll merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948615#comment-14948615
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on the pull request:
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-146555847
Thanks, @mxm ;)
---
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
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41518461
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41518435
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -18,48 +18,74 @@
package
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948722#comment-14948722
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948625#comment-14948625
]
ASF GitHub Bot commented on FLINK-2808:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1239#discussion_r41509657
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
---
@@ -471,7
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948632#comment-14948632
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user mbalassi commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2835.
Resolution: Fixed
This is a duplicate of FLINK-2779.
PR #1208 addresses this issue and can still be
Matthias J. Sax created FLINK-2836:
--
Summary: Cyclic Topologies not supported
Key: FLINK-2836
URL: https://issues.apache.org/jira/browse/FLINK-2836
Project: Flink
Issue Type: Improvement
Matthias J. Sax created FLINK-2837:
--
Summary: FlinkTopologyBuilder cannot handle multiple input streams
Key: FLINK-2837
URL: https://issues.apache.org/jira/browse/FLINK-2837
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948717#comment-14948717
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948800#comment-14948800
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user nikste commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948820#comment-14948820
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user uce commented on a diff in the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41527148
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java
---
@@ -0,0 +1,76 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41527783
--- 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=14948841#comment-14948841
]
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=14948851#comment-14948851
]
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-2834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948881#comment-14948881
]
Stephan Ewen commented on FLINK-2834:
-
+1, I think that is important for larger setups
> Global
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1494#comment-1494
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948772#comment-14948772
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user nikste commented on the pull request:
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-146573493
@chiwanpark issues should be fixed NOW ;)
---
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-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948798#comment-14948798
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user nikste commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948802#comment-14948802
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user danielblazevski commented on a diff in the pull
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-146576052
@mbalassi: is the operator chaining currently documented somewhere? Same
about partitioning between operators of different parallelism
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948825#comment-14948825
]
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_r41526810
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -0,0 +1,310 @@
+/*
+ *
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1234#issuecomment-146578397
@StephanEwen I think so.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948836#comment-14948836
]
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-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948835#comment-14948835
]
ASF GitHub Bot commented on FLINK-2156:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948837#comment-14948837
]
ASF GitHub Bot commented on FLINK-2156:
---
Github user chiwanpark commented on the pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1242
[FLINK-2780] Remove Old Windowing Logic and API
This rewrites the few examples and tests that are remaining using the new
Windowing API.
You can merge this pull request into a Git repository by
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1239#discussion_r41528403
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -322,73
[
https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948855#comment-14948855
]
ASF GitHub Bot commented on FLINK-2808:
---
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=14948892#comment-14948892
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948782#comment-14948782
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user chiwanpark commented on a diff in the pull
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1186#issuecomment-146570848
Okay, We need some discussion in mailing list about ML model import/export
feature. I think that PMML support is one of sub-issues related to the ML model
Github user nikste commented on a diff in the pull request:
https://github.com/apache/flink/pull/1106#discussion_r41525031
--- Diff:
flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala
---
@@ -225,8 +223,50 @@ class ScalaShellITSuite
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948810#comment-14948810
]
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_r41526216
--- 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=14948826#comment-14948826
]
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_r41526930
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java
---
@@ -0,0 +1,105 @@
+/*
+ *
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41527578
--- 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=14948884#comment-14948884
]
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_r41531181
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -0,0 +1,380 @@
+/*
+ *
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-146568015
@chiwanpark issues should be fixed now..
---
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
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1220#discussion_r41526734
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala ---
@@ -0,0 +1,305 @@
+
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948823#comment-14948823
]
ASF GitHub Bot commented on FLINK-1745:
---
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=14948830#comment-14948830
]
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=14948844#comment-14948844
]
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-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948849#comment-14948849
]
ASF GitHub Bot commented on FLINK-2808:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948848#comment-14948848
]
ASF GitHub Bot commented on FLINK-2780:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948880#comment-14948880
]
Stephan Ewen commented on FLINK-2750:
-
The test is reworked in my latest pull request (state backend
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41531112
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -0,0 +1,380 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41531592
--- 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=14948895#comment-14948895
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a diff in the pull
101 - 200 of 269 matches
Mail list logo
