[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385721#comment-14385721 ] Mathusuthan Kannan commented on FLINK-1711: --- Hi, I would like to work on this

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-87425953 Hi @vasia , 1). I will add the documentation once we reach a consensus. No use documenting something that might change :) 2). For the public setter: I

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385800#comment-14385800 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu commented on the

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385727#comment-14385727 ] Fabian Hueske commented on FLINK-1711: -- Welcome to the Flink community! I assigned

[jira] [Resolved] (FLINK-1796) Local mode TaskManager should have a process reaper

[ https://issues.apache.org/jira/browse/FLINK-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1796. - Resolution: Fixed Fixed via 8c32142528590a030693529c7c8d93f194968c0a Local mode TaskManager

[jira] [Resolved] (FLINK-1795) Solution set allows duplicates upon construction.

[ https://issues.apache.org/jira/browse/FLINK-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1795. - Resolution: Fixed Fixed via 923a2ae259bd72a2d48639ae0e64db0a04a4aa91 Solution set allows

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385666#comment-14385666 ] narayana reddy commented on FLINK-1421: --- Hello Parris Carbone,

[GitHub] flink pull request: Make Expression API available to Java, Rename ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/503 --- 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

[jira] [Resolved] (FLINK-1623) Rename Expression API and Operation Representation

[ https://issues.apache.org/jira/browse/FLINK-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1623. - Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Updated] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1711: - Assignee: Mathusuthan Kannan Replace all usages off commons.Validate with guava.check

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385915#comment-14385915 ] ASF GitHub Bot commented on FLINK-1523: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-87462312 Hi @andralungu! Regarding (2), I think you could do that inside VertexCentricIteration instead of inside a method of Graph. Regarding (3), I agree that adding

[jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method

[ https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385955#comment-14385955 ] ASF GitHub Bot commented on FLINK-1633: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/452#issuecomment-87475338 Hi, I got the following in my local Travis setup: `Failed tests: ChainTaskTestTaskTestBase.shutdownMemoryManager:163 Memory Manager managed memory was

[jira] [Resolved] (FLINK-1669) Streaming tests for recovery with distributed process failure

[ https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1669. - Resolution: Fixed Fixed in c284745ee4612054339842789b0d87eb4f9a821d Streaming tests for

[jira] [Assigned] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-1694: Assignee: Vasia Kalavri Change the split between create/run of a vertex-centric iteration

[GitHub] flink pull request: [FLINK-1669] [wip] Test for streaming recovery...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/496 --- 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

[jira] [Commented] (FLINK-1669) Streaming tests for recovery with distributed process failure

[ https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385912#comment-14385912 ] ASF GitHub Bot commented on FLINK-1669: --- Github user asfgit closed the pull request