[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388143#comment-14388143
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388140#comment-14388140
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388142#comment-14388142
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87967427
Thank you very much for the review Henry!
I addressed your feedback where applicable. I'll merge the change now.
---
If your project is set up for it, you can re
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456302
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java ---
@@ -106,70 +111,129 @@ public FlinkYarnCluster(final YarnClient yarnClient,
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456299
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -265,12 +266,32 @@ protected int run(String[] args) {
}
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388137#comment-14388137
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388138#comment-14388138
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456233
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -89,15 +89,20 @@ public void setPrintStatusDuringExecution(boolean
pr
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456244
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -569,15 +590,33 @@ protected int executeProgram(PackagedProgram program,
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388135#comment-14388135
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456228
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CustomPartitioningGroupingTupleTest.scala
---
@@ -18,12 +18,12 @@
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456202
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
---
@@ -80,7 +80,7 @@ public String getExecutionPlan() throws Except
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14388133#comment-14388133
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387978#comment-14387978
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87936262
While it is a big patch, with the additional comments I was able to follow
your changes. The main changes look good, so the rest I assume is side effect
to make the refac
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27452585
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java ---
@@ -106,70 +111,129 @@ public FlinkYarnCluster(final YarnClient yarnClient,
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387970#comment-14387970
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387967#comment-14387967
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27452529
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CustomPartitioningGroupingTupleTest.scala
---
@@ -18,12 +18,12 @@
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387966#comment-14387966
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27452509
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
---
@@ -80,7 +80,7 @@ public String getExecutionPlan() throws Except
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387958#comment-14387958
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27452411
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -89,15 +89,20 @@ public void setPrintStatusDuringExecution(boolean
pr
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387943#comment-14387943
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27452062
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -569,15 +590,33 @@ protected int executeProgram(PackagedProgram program,
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387939#comment-14387939
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27451902
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -265,12 +266,32 @@ protected int run(String[] args) {
}
[
https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387919#comment-14387919
]
ASF GitHub Bot commented on FLINK-1797:
---
GitHub user ggevay opened a pull request:
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/549
[FLINK-1797] Add jumping pre-reducer for Count and Time windows
I created 4 classes: for count and time windows, and their grouped
versions. They extend the corresponding (grouped/non-grouped)
Tumbli
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/548
Add --abbrev-ref to get the right branch name of HEAD
Add --abbrev-ref to get the right branch name of HEAD rather than checksum
to return back to original branch.
Without it will make merg
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387641#comment-14387641
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/546#issuecomment-87879789
+1 LGTM
Once Travis done will merge unless more review coming in. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply a
Github user matadorhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/546#discussion_r27441775
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java
---
@@ -43,7 +45,10 @@
/** Flag to sign
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387591#comment-14387591
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user matadorhong commented on a diff
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87840336
I know that the PR is touching many components. I'll try to split up my
work into smaller parts.
In this case I didn't expect in the beginning that I need to change so
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387465#comment-14387465
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387398#comment-14387398
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/544#issuecomment-87830769
Hi @vasia ,
The problem(at least mine) was that Jaccard works on both an undirected and
on a directed graph... and I just needed to make a final decision :). D
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87817661
@rmetzger, the PR is too large to do effective review =(
Could you kindly summarize the significant changes made to fix this? For
example why introduce new class
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387329#comment-14387329
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-87798034
Confirmed ;)
Looking forward talking to you tomorrow. My google hangout id is
metrob...@gmail.com.
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387260#comment-14387260
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user rmetzger commented on the pull
Github user bhatsachin commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-87796282
Great. 17:00 India Time Zone (UTC+05:30) would be perfect.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387250#comment-14387250
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user bhatsachin commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387144#comment-14387144
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-87781100
Cool.
I'm available between 16:30 - 20:30 India Time Zone (UTC+05:30). Is that
possible for you?
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387135#comment-14387135
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87780049
A user I'm talking with offline depends on these changes.
I'm currently hardening the tests on Travis, once that's done I'll merge
the changes (probably in the next 12
[
https://issues.apache.org/jira/browse/FLINK-1801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1801.
-
Resolution: Implemented
Implemented in ee273dbe01e95d2b260fa690e21e2c244a2a5711
> NetworkEnvironm
[
https://issues.apache.org/jira/browse/FLINK-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1465.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen (was: Ufuk Celebi)
Fi
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387100#comment-14387100
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user bhatsachin commented on the pul
Github user bhatsachin commented on the pull request:
https://github.com/apache/flink/pull/421#issuecomment-87776384
Thanks a lot Robert, let us have a hangout session tomorrow (Tuesday).
Please suggest a time of your convenience. My other friends from IIT Mandi will
also join in.
-
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14387000#comment-14387000
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/546#discussion_r27410240
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java
---
@@ -43,7 +45,10 @@
/** Flag to signify
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27408604
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386980#comment-14386980
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/544#issuecomment-87751974
Hey @andralungu! Thanks a lot for this PR. I have left some inline
comments. Basically, it's not very clear (at least to me) whether you're
working on a directed or undirect
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27408463
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386967#comment-14386967
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27409101
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386976#comment-14386976
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386974#comment-14386974
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27408830
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386969#comment-14386969
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386966#comment-14386966
]
Stephan Ewen commented on FLINK-1465:
-
This is actually an integer overflow issue.
I
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386964#comment-14386964
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27408109
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386962#comment-14386962
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/544#discussion_r27407901
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/JaccardSimilarityMeasureExample.java
---
@@ -0,0 +1,207 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1435.
-
Resolution: Not a Problem
> TaskManager does not log missing memory error on start up
> --
[
https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386949#comment-14386949
]
Stephan Ewen commented on FLINK-1435:
-
I think we misunderstood this issue initially.
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-1522:
Assignee: Vasia Kalavri (was: Daniel Bali)
> Add tests for the library methods and example
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386869#comment-14386869
]
Daniel Bali commented on FLINK-1522:
Yeah, I'm not working on this right now.
> Add t
[
https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386867#comment-14386867
]
ASF GitHub Bot commented on FLINK-1794:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386865#comment-14386865
]
Vasia Kalavri commented on FLINK-1522:
--
[~balidani], [~andralungu] if I'm not mistake
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/540#issuecomment-87723741
If there are no objections, then I would merge this PR. My other PRs depend
on this as well.
---
If your project is set up for it, you can reply to this email and ha
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386854#comment-14386854
]
ASF GitHub Bot commented on FLINK-1694:
---
GitHub user vasia opened a pull request:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/547
[FLINK-1694] [gelly] added IterationConfiguration as a way to configure ...
...a VertexCentricIteration and avoid the split between create and run
methods.
You can merge this pull request into a Git r
[
https://issues.apache.org/jira/browse/FLINK-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386820#comment-14386820
]
ASF GitHub Bot commented on FLINK-1716:
---
GitHub user tillrohrmann opened a pull requ
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/546
The class IOManagerAsync should use its own Log instance
Although class 'IOManagerAsync' is extended from 'IOManager' in package
'org.apache.flink.runtime.io.disk.iomanager', but I think it shoul
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/545
[FLINK-1716] Adds CoCoA algorithm
This PR adds the CoCoA algorithm using l2-norm and hinge-loss functions.
Thus, it can be used to train soft-margin SVM.
This PR is based on #539 and #5
Sibao Hong created FLINK-1805:
-
Summary: The class IOManagerAsync(in
org.apache.flink.runtime.io.disk.iomanager) should use its own Log
Key: FLINK-1805
URL: https://issues.apache.org/jira/browse/FLINK-1805
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386792#comment-14386792
]
Robert Metzger commented on FLINK-1650:
---
I'm going to set the Akka version back to 2
Robert Metzger created FLINK-1804:
-
Summary: flink-quickstart-scala tests fail on scala-2.11 build
profile on travis
Key: FLINK-1804
URL: https://issues.apache.org/jira/browse/FLINK-1804
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386671#comment-14386671
]
ASF GitHub Bot commented on FLINK-1741:
---
GitHub user andralungu opened a pull reques
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/544
[FLINK-1741][gelly] Adds Jaccard Similarity Metric Example
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/andralungu/flink flinkJaccard
Alte
Gyula Fora created FLINK-1803:
-
Summary: Add type hints to the streaming api
Key: FLINK-1803
URL: https://issues.apache.org/jira/browse/FLINK-1803
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1802:
---
Summary: BlobManager directories should be checked before
TaskManager startup
Key: FLINK-1802
URL: https://issues.apache.org/jira/browse/FLINK-1802
Project: Flink
Stephan Ewen created FLINK-1801:
---
Summary: NetworkEnvironment should start without JobManager
association
Key: FLINK-1801
URL: https://issues.apache.org/jira/browse/FLINK-1801
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1754.
-
Resolution: Not a Problem
Is actually a known bug in 0.8 and fixed in 0.9
> Deadlock in job execu
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1774.
-
Resolution: Fixed
Fixed in c89c657ae16bbe89da54669a234713a3811813ee
Thank you for the patch!
> R
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1779.
-
Resolution: Fixed
Fixed in fb3f3ee845a3aae295c9aae00f3d406d9f1d5813
Thank you for the patch!
> R
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386612#comment-14386612
]
ASF GitHub Bot commented on FLINK-1779:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386611#comment-14386611
]
ASF GitHub Bot commented on FLINK-1774:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/529
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/522
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1662:
--
Assignee: Péter Szabó
> NullFieldException is thrown when testing IterativeDataStream with tuples,
> wi
Robert Metzger created FLINK-1800:
-
Summary: Add a "Beta" badge in the documentation to components in
flink-staging
Key: FLINK-1800
URL: https://issues.apache.org/jira/browse/FLINK-1800
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1348.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed with the updated dependency management in the re
1 - 100 of 121 matches
Mail list logo
