[GitHub] flink pull request: check in if clause in LongValue.java

2015-06-17 Thread sahitya-pavurala
GitHub user sahitya-pavurala opened a pull request: https://github.com/apache/flink/pull/849 check in if clause in LongValue.java Should be logical() and not bit wise() You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

2015-06-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/818#issuecomment-112923172 Hi @shghatge! For this issue, I think we should only add the `difference` method. If you want to avoid duplicating code, you can always define a private helper

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

2015-06-17 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590464#comment-14590464 ] Vasia Kalavri commented on FLINK-2235: -- We ran into the same issue today at the

[jira] [Created] (FLINK-2237) Add hash-based Aggregation

2015-06-17 Thread Rafiullah Momand (JIRA)
Rafiullah Momand created FLINK-2237: --- Summary: Add hash-based Aggregation Key: FLINK-2237 URL: https://issues.apache.org/jira/browse/FLINK-2237 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2015-06-17 Thread Shakirullah (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590360#comment-14590360 ] Shakirullah commented on FLINK-2237: We are TU-Berlin, IMPRO-3 course students and we

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590420#comment-14590420 ] ASF GitHub Bot commented on FLINK-2093: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-2140) Access the number of vertices from within the GSA functions

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590489#comment-14590489 ] ASF GitHub Bot commented on FLINK-2140: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-2140][gelly] Allowed access to the numb...

2015-06-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/779#issuecomment-112933533 +1, looks good! --- 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

[jira] [Commented] (FLINK-2178) groupReduceOnNeighbors throws NoSuchElementException

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590520#comment-14590520 ] ASF GitHub Bot commented on FLINK-2178: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590556#comment-14590556 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672972 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672778 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590559#comment-14590559 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673063 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590558#comment-14590558 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590580#comment-14590580 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674875 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590690#comment-14590690 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590740#comment-14590740 ] ASF GitHub Bot commented on FLINK-2180: --- Github user gaborhermann commented on the

[GitHub] flink pull request: [FLINK-2178][gelly] Fixed groupReduceOnNeighbo...

2015-06-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/799#issuecomment-112940323 Perfect, thanks @andralungu! +1 --- 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

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673548 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590591#comment-14590591 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674326 --- Diff: docs/libs/gelly_guide.md --- @@ -102,6 +102,15 @@ DataSetTuple3String, String, Double edgeTuples = env.readCsvFile(path/to/ed GraphString,

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674993 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590599#comment-14590599 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674908 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590607#comment-14590607 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590606#comment-14590606 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590605#comment-14590605 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590601#comment-14590601 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674944 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590557#comment-14590557 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672827 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590554#comment-14590554 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673806 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590563#comment-14590563 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590609#comment-14590609 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32675117 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32676277 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590623#comment-14590623 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590627#comment-14590627 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590633#comment-14590633 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-112954221 Hey @shghatge, this is a great first try, you got the logic right and I really like the detailed javadocs ^^ I left a few inline comments, which should be easy

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2015-06-17 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590727#comment-14590727 ] Alexander Alexandrov commented on FLINK-2237: - In the Flink RT, operators are

[GitHub] flink pull request: check in if clause in LongValue.java

2015-06-17 Thread sahitya-pavurala
Github user sahitya-pavurala commented on the pull request: https://github.com/apache/flink/pull/849#issuecomment-112940775 It looks like I deleted my local repository accidentally. Let me know if I have to make this change again. --- If your project is set up for it, you can reply

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672995 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590561#comment-14590561 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673105 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673158 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674930 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590603#comment-14590603 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590604#comment-14590604 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674923 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32674967 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32675011 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590602#comment-14590602 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32676617 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-2180] [streaming] Iteration test fix

2015-06-17 Thread gaborhermann
Github user gaborhermann commented on the pull request: https://github.com/apache/flink/pull/802#issuecomment-112968975 I updated the PR. Added the fix for the iteration test. Probably not getting a new element within the maximum wait time caused the failing of the iteration tests.

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590575#comment-14590575 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590614#comment-14590614 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32675480 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request: Modified the equals method in all the Value ty...

2015-06-17 Thread sahitya-pavurala
GitHub user sahitya-pavurala opened a pull request: https://github.com/apache/flink/pull/850 Modified the equals method in all the Value type classes Added check for null in all the equals methods in all the Value type classes You can merge this pull request into a Git

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672805 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32672727 --- Diff: docs/libs/gelly_guide.md --- @@ -102,6 +102,15 @@ DataSetTuple3String, String, Double edgeTuples = env.readCsvFile(path/to/ed GraphString, Long,

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673221 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590566#comment-14590566 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673330 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -282,6 +282,58 @@ public void flatMap(EdgeK, EV edge,

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590572#comment-14590572 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-06-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r32673274 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590568#comment-14590568 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14590584#comment-14590584 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in

[GitHub] flink pull request: New operator state interfaces

2015-06-17 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/747#issuecomment-112765188 Some issues that we need to fix before merge: Committing the checkpoint doesnt work properly. We need to commit the states one by one and also pass the names for

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32619450 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/730#issuecomment-112776948 Maven verify does not complete. There are apparently files which don't contain the Apache license header. This failure should be visible when you run `mvn clean

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32620238 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: Csv read graph

2015-06-17 Thread shghatge
GitHub user shghatge opened a pull request: https://github.com/apache/flink/pull/846 Csv read graph [FLINK-1520]Read edges and vertices from CSV files Changes done- 1) Added a GraphCsvReader class which has 2 CsvReaders as members EdgeReader and VertexReader

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589674#comment-14589674 ] ASF GitHub Bot commented on FLINK-1520: --- GitHub user shghatge opened a pull request:

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread aalexandrov
Github user aalexandrov commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32620391 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread FGoessler
Github user FGoessler commented on the pull request: https://github.com/apache/flink/pull/730#issuecomment-112761494 Is something going to happen with this pull request soon, cause we would need a working TF-IDF-Transformer for another project? --- If your project is set up for it,

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32619716 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32620542 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32620440 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32619656 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32619636 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32620153 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-2210) Table API aggregate by ignoring null values

2015-06-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2210. --- Resolution: Fixed Fix Version/s: 0.9 Implemented in

[jira] [Commented] (FLINK-2217) Web client does not remove uploaded JARs

2015-06-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589397#comment-14589397 ] Flavio Pompermaier commented on FLINK-2217: --- The upload date (and also size or

[jira] [Commented] (FLINK-2211) Generalize ALS API

2015-06-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589491#comment-14589491 ] Till Rohrmann commented on FLINK-2211: -- The number of factors should actually never

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589533#comment-14589533 ] ASF GitHub Bot commented on FLINK-1745: --- Github user chiwanpark commented on the

[GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne...

2015-06-17 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/696#issuecomment-112745989 @thvasilo Good! Thank you. I'll update the implementation after #801 is merged. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589590#comment-14589590 ] ASF GitHub Bot commented on FLINK-1745: --- Github user chiwanpark commented on the

[jira] [Commented] (FLINK-2211) Generalize ALS API

2015-06-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589599#comment-14589599 ] Till Rohrmann commented on FLINK-2211: -- I thought we were talking about making the

[GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne...

2015-06-17 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/696#issuecomment-112733734 Hi. I updated the implementation of kNN using pipeline architecture. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2211) Generalize ALS API

2015-06-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589562#comment-14589562 ] Ronny Bräunlich commented on FLINK-2211: I guess then we can close this issue as

[jira] [Commented] (FLINK-2211) Generalize ALS API

2015-06-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589604#comment-14589604 ] Till Rohrmann commented on FLINK-2211: -- If you have more items than {{2^31-1}} then

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32623295 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32623851 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-1999] basic TfidfTransformer

2015-06-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/730#discussion_r32624395 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala --- @@ -0,0 +1,128 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-2235) Local Flink cluster allocates too much memory

2015-06-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2235: -- Environment: Oracle JDK: 1.6.0_65-b14-462 Eclipse was: Oracle JDK 1.6 Eclipse

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589770#comment-14589770 ] ASF GitHub Bot commented on FLINK-1520: --- Github user shghatge closed the pull

  1   2   >