Hi Olga, On 21 September 2016 at 18:50, Olga Golovneva <melcha...@gmail.com> wrote:
> Hi devs, > > I was working on (FLINK-1526) "Add Minimum Spanning Tree library method > and example" issue. I've developed (Java) code that implements distributed > Boruvka's algorithm in Gelly library. I've run several tests and it seems > to work fine, although I didn't test it on extremely large input graphs > yet, and I'm also trying to optimize my code. > Particularly, I have two main issues: > > 1. Nested loops. > I have to use nested loops, and I do not see the way to avoid them. As > they are currently not supported, I'm using Bulk Iterations inside a > "classic" while loop. I've included in attachment simple example > MyNestedIterationExample that shows this issue. > I think you cannot add attachments to the mailing list. Could you upload your example somewhere and post a link here? I'm actually surprised that the while-loop works without problems. > > 2. For some reason I cannot create class that works with types with > generic variables in Tuple2(or Tuple3), thus my code does not support > generic types. I also included simple example MyTuple3Example. Here is the > Exception I get: > "Exception in thread "main" > org.apache.flink.api.common.functions.InvalidTypesException: > Type of TypeVariable 'EV' in 'class org.apache.flink.graph. > examples.MyTuple3Example$InitializeEdges' could not be determined. This > is most likely a type erasure problem. The type extraction currently > supports types with generic variables only in cases where all variables in > the return type can be deduced from the input type(s)." > Can you upload this example and link to it too? Thanks, -Vasia. > > I would really appreciate if someone could explain me know how to avoid > this Exception. Otherwise, I could submit my code for testing. > > Best regards, > Olga Golovneva >
