Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/452
---
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
[
https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386481#comment-14386481
]
ASF GitHub Bot commented on FLINK-1633:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1633.
--
Resolution: Implemented
Fix Version/s: 0.9
Add getTriplets() Gelly method
Péter Szabó created FLINK-1798:
--
Summary: Bug in IterateExample while running with parallelism 1:
broker slot is already occupied
Key: FLINK-1798
URL: https://issues.apache.org/jira/browse/FLINK-1798
[
https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386418#comment-14386418
]
ASF GitHub Bot commented on FLINK-1633:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/452#issuecomment-87600209
@vasia: I think the error is not related to the PR and it only happened in
one out of 10 builds. Its not good that it failed but it should not block you
from merging
[
https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó updated FLINK-1798:
---
Component/s: Streaming
Bug in IterateExample while running with parallelism 1: broker slot is
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:
[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386611#comment-14386611
]
ASF GitHub Bot commented on FLINK-1774:
---
Github user asfgit closed the pull request
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
[
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,
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/529#issuecomment-87633234
Looks good, will merge this...
---
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
Till Rohrmann created FLINK-1799:
Summary: Scala API does not support generic arrays
Key: FLINK-1799
URL: https://issues.apache.org/jira/browse/FLINK-1799
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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:all-tabpanel
]
Stephan Ewen resolved FLINK-1774.
-
Resolution: Fixed
Fixed in c89c657ae16bbe89da54669a234713a3811813ee
Thank you for the patch!
[
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!
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
[
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386792#comment-14386792
]
Robert Metzger commented on FLINK-1650:
---
I'm going to set the Akka version back to
[
https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386867#comment-14386867
]
ASF GitHub Bot commented on FLINK-1794:
---
Github user tillrohrmann commented on the
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-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386820#comment-14386820
]
ASF GitHub Bot commented on FLINK-1716:
---
GitHub user tillrohrmann opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386865#comment-14386865
]
Vasia Kalavri commented on FLINK-1522:
--
[~balidani], [~andralungu] if I'm not
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
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
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386854#comment-14386854
]
ASF GitHub Bot commented on FLINK-1694:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386869#comment-14386869
]
Daniel Bali commented on FLINK-1522:
Yeah, I'm not working on this right now.
Add
[
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
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386976#comment-14386976
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in
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 @@
+/*
+ *
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 @@
+/*
+ *
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-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386969#comment-14386969
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in
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 @@
+/*
+ *
[
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-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387100#comment-14387100
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user bhatsachin commented on the
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386962#comment-14386962
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387000#comment-14387000
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user hsaputra commented on a diff in
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 @@
+/*
+ *
[
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
[
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)
[
https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386949#comment-14386949
]
Stephan Ewen commented on FLINK-1435:
-
I think we misunderstood this issue initially.
[
https://issues.apache.org/jira/browse/FLINK-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14386980#comment-14386980
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386967#comment-14386967
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on a diff in
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
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387250#comment-14387250
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user bhatsachin commented on the
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387135#comment-14387135
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on the pull
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-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
[
https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387260#comment-14387260
]
ASF GitHub Bot commented on FLINK-1501:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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/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
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
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 :).
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
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387591#comment-14387591
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user matadorhong commented on a diff
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
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)
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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_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-tabpanelfocusedCommentId=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_r27452585
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java ---
@@ -106,70 +111,129 @@ public FlinkYarnCluster(final YarnClient
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387919#comment-14387919
]
ASF GitHub Bot commented on FLINK-1797:
---
GitHub user ggevay opened a pull request:
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-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387939#comment-14387939
]
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-tabpanelfocusedCommentId=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
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14387978#comment-14387978
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on the pull
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
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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_r27452509
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
---
@@ -80,7 +80,7 @@ public String getExecutionPlan() throws
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
79 matches
Mail list logo
