[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Created] (FLINK-2411) Add basic graph summarization algorithm

Martin Junghanns created FLINK-2411: --- Summary: Add basic graph summarization algorithm Key: FLINK-2411 URL: https://issues.apache.org/jira/browse/FLINK-2411 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980450#comment-14980450 ] Martin Junghanns edited comment on FLINK-2905 at 10/29/15 1:54 PM: --- Hi,

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980450#comment-14980450 ] Martin Junghanns commented on FLINK-2905: - Hi, taking your reply on the mailing list into account,

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14972499#comment-14972499 ] Martin Junghanns commented on FLINK-2905: - Hi [~vkalavri]! Short question: As we do not have

[jira] [Created] (FLINK-2910) Combine tests for binary graph operators

Martin Junghanns created FLINK-2910: --- Summary: Combine tests for binary graph operators Key: FLINK-2910 URL: https://issues.apache.org/jira/browse/FLINK-2910 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2910) Combine tests for binary graph operators

[ https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2910: Description: Atm, testing a binary operator (i.e. union and difference) is done in two

[jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976525#comment-14976525 ] Martin Junghanns edited comment on FLINK-2905 at 10/27/15 3:05 PM: ---

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976525#comment-14976525 ] Martin Junghanns commented on FLINK-2905: - Sorry for the confusion. In the example, I focused on

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976739#comment-14976739 ] Martin Junghanns commented on FLINK-2905: - I totally agree with your definition of graph

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976461#comment-14976461 ] Martin Junghanns commented on FLINK-2905: - Hi, I agree with you that Option 3 is the most

[jira] [Created] (FLINK-2905) Add intersect method to Graph class

Martin Junghanns created FLINK-2905: --- Summary: Add intersect method to Graph class Key: FLINK-2905 URL: https://issues.apache.org/jira/browse/FLINK-2905 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector

[ https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985420#comment-14985420 ] Martin Junghanns commented on FLINK-2941: - I assigned it to me for the moment as I am working on

[jira] [Assigned] (FLINK-2941) Implement a neo4j - Flink/Gelly connector

[ https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns reassigned FLINK-2941: --- Assignee: Martin Junghanns > Implement a neo4j - Flink/Gelly connector >

[jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14988155#comment-14988155 ] Martin Junghanns edited comment on FLINK-2905 at 11/4/15 7:11 AM: -- Hi

[jira] [Created] (FLINK-2981) Update README for building docs

Martin Junghanns created FLINK-2981: --- Summary: Update README for building docs Key: FLINK-2981 URL: https://issues.apache.org/jira/browse/FLINK-2981 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2981) Update README for building docs

[ https://issues.apache.org/jira/browse/FLINK-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14993456#comment-14993456 ] Martin Junghanns commented on FLINK-2981: - Yes, of course. > Update README for building docs >

[jira] [Commented] (FLINK-2905) Add intersect method to Graph class

[ https://issues.apache.org/jira/browse/FLINK-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989264#comment-14989264 ] Martin Junghanns commented on FLINK-2905: - Hi, this is a good idea. We need to make too many

[jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951892#comment-14951892 ] Martin Junghanns commented on FLINK-2411: - Hi, I finally found some time to implement that :) I am

[jira] [Comment Edited] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951892#comment-14951892 ] Martin Junghanns edited comment on FLINK-2411 at 10/10/15 3:44 PM: --- Hi,

[jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm

[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14952217#comment-14952217 ] Martin Junghanns commented on FLINK-2411: - Yes, but the idea was to give the user a way to just

[jira] [Updated] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs

[ https://issues.apache.org/jira/browse/FLINK-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2590: Affects Version/s: 0.10 DataSetUtils.zipWithUniqueID creates duplicate IDs

[jira] [Created] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs

Martin Junghanns created FLINK-2590: --- Summary: DataSetUtils.zipWithUniqueID creates duplicate IDs Key: FLINK-2590 URL: https://issues.apache.org/jira/browse/FLINK-2590 Project: Flink Issue

[jira] [Updated] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs

[ https://issues.apache.org/jira/browse/FLINK-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2590: Description: The function creates IDs using the following code: {code:java} shifter =

[jira] [Updated] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs

[ https://issues.apache.org/jira/browse/FLINK-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2590: Description: The function creates IDs using the following code: {code:java} shifter =

[jira] [Issue Comment Deleted] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2602: Comment: was deleted (was: That were the two spots I also found. Closing the issue.) >

[jira] [Resolved] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns resolved FLINK-2602. - Resolution: Fixed Fix Version/s: 0.10 Already fixed in hotfix

[jira] [Commented] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728598#comment-14728598 ] Martin Junghanns commented on FLINK-2602: - That were the two spots I also found. Closing the

[jira] [Commented] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14725457#comment-14725457 ] Martin Junghanns commented on FLINK-2602: - I could work on that, good way to scan through the

[jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045067#comment-15045067 ] Martin Junghanns commented on FLINK-3118: - If there is no objection, I would continue and

[jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

Martin Junghanns created FLINK-3118: --- Summary: Check if MessageFunction implements ResultTypeQueryable Key: FLINK-3118 URL: https://issues.apache.org/jira/browse/FLINK-3118 Project: Flink

[jira] [Comment Edited] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041745#comment-15041745 ] Martin Junghanns edited comment on FLINK-3118 at 12/4/15 4:47 PM: -- I am

[jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041745#comment-15041745 ] Martin Junghanns commented on FLINK-3118: - I am not so familiar with the type extraction

[jira] [Comment Edited] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041745#comment-15041745 ] Martin Junghanns edited comment on FLINK-3118 at 12/4/15 4:46 PM: -- I am

[jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15043291#comment-15043291 ] Martin Junghanns commented on FLINK-3118: - I also tried that and let {{MessageFunction}} implement

[jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15043294#comment-15043294 ] Martin Junghanns commented on FLINK-3118: - Sorry, didn't think this through. It would of course

[jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation

Martin Junghanns created FLINK-3122: --- Summary: Generalize value type in LabelPropagation Key: FLINK-3122 URL: https://issues.apache.org/jira/browse/FLINK-3122 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15063684#comment-15063684 ] Martin Junghanns commented on FLINK-2315: - Hi, is this hard to fix? I wanted to apply that exact

[jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15080878#comment-15080878 ] Martin Junghanns commented on FLINK-2315: - I looked into the two classes. They are nearly

[jira] [Created] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE

Martin Junghanns created FLINK-3064: --- Summary: Missing size check in GroupReduceOperatorBase leads to NPE Key: FLINK-3064 URL: https://issues.apache.org/jira/browse/FLINK-3064 Project: Flink

[jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector

[ https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15170625#comment-15170625 ] Martin Junghanns commented on FLINK-2941: - I finished the input and output formats

[jira] [Created] (FLINK-3272) Generalize vertex value type in ConnectedComponents

Martin Junghanns created FLINK-3272: --- Summary: Generalize vertex value type in ConnectedComponents Key: FLINK-3272 URL: https://issues.apache.org/jira/browse/FLINK-3272 Project: Flink

[jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15108203#comment-15108203 ] Martin Junghanns commented on FLINK-2315: - Hi [~StephanEwen], I checked my 'NormalizableKey &

[jira] [Created] (FLINK-3611) Wrong link in CONTRIBUTING.md

Martin Junghanns created FLINK-3611: --- Summary: Wrong link in CONTRIBUTING.md Key: FLINK-3611 URL: https://issues.apache.org/jira/browse/FLINK-3611 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation

Martin Junghanns created FLINK-3618: --- Summary: Rename abstract UDF classes in Scatter-Gather implementation Key: FLINK-3618 URL: https://issues.apache.org/jira/browse/FLINK-3618 Project: Flink

[jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector

[ https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179492#comment-15179492 ] Martin Junghanns commented on FLINK-2941: - Hi, thank you guys for the input! Forking it into

[jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation

[ https://issues.apache.org/jira/browse/FLINK-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275179#comment-15275179 ] Martin Junghanns commented on FLINK-3618: - [~greghogan] thanks for taking this. I'm currently a

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509534#comment-15509534 ] Martin Junghanns commented on FLINK-4624: - Thanks for the explanation, it now works as expected.

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15502534#comment-15502534 ] Martin Junghanns commented on FLINK-4624: - As stated on the mailing list, the problem is that the

[jira] [Assigned] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns reassigned FLINK-4624: --- Assignee: Martin Junghanns > Gelly's summarization algorithm cannot deal with null

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505926#comment-15505926 ] Martin Junghanns commented on FLINK-4624: - You were right, I had a private member in the UDF for

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15506100#comment-15506100 ] Martin Junghanns commented on FLINK-4624: - Thanks for the explanation. As I need

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504447#comment-15504447 ] Martin Junghanns commented on FLINK-4624: - No, I wanted to have an {{Either}} as

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15506539#comment-15506539 ] Martin Junghanns commented on FLINK-4624: - Yes, I looked into the two constructors before. The one

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15542267#comment-15542267 ] Martin Junghanns commented on FLINK-4624: - ping [~greghogan] > Gelly's summarization algorithm

[jira] [Created] (FLINK-4872) Type erasure problem exclusively on cluster execution

Martin Junghanns created FLINK-4872: --- Summary: Type erasure problem exclusively on cluster execution Key: FLINK-4872 URL: https://issues.apache.org/jira/browse/FLINK-4872 Project: Flink

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15670241#comment-15670241 ] Martin Junghanns commented on FLINK-4872: - [~twalthr] Thanks for looking into it. The actuacl UDF

[jira] [Comment Edited] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15670241#comment-15670241 ] Martin Junghanns edited comment on FLINK-4872 at 11/16/16 11:44 AM:

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15671192#comment-15671192 ] Martin Junghanns commented on FLINK-4872: - I just reproduced it using the following steps: *

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15682781#comment-15682781 ] Martin Junghanns commented on FLINK-4872: - [~twalthr] Thank you! I will test it this week and