Re: Compiler Exception

2015-11-20 Thread Truong Duc Kien
Hi Jill, Thank you very much. Looking forward to trying the fix. Best, Kien On Fri, Nov 20, 2015 at 12:38 PM, Till Rohrmann wrote: > Hi Kien Truong, > > I found a solution to your problem. It's actually a bug in Flink's > optimizer. Thanks for spotting it :-) > > I've opened a pull request to

Re: Compiler Exception

2015-11-20 Thread Till Rohrmann
Hi Kien Truong, I found a solution to your problem. It's actually a bug in Flink's optimizer. Thanks for spotting it :-) I've opened a pull request to fix it ( https://github.com/apache/flink/pull/1388). The fix will also be included in the upcoming `0.10.1` release. After the pull request has be

Re: Compiler Exception

2015-11-19 Thread Truong Duc Kien
Hi Till, I have narrowed down a minimal test case, you will need flink-gelly-scala package to run this. import org.apache.flink.api.common.functions.MapFunction import org.apache.flink.api.scala._ import org.apache.flink.graph._ import org.apache.flink.graph.scala.Graph import org.apache.flink

Re: Compiler Exception

2015-11-19 Thread Till Rohrmann
Hi Kien Truong, could you share the problematic code with us? Cheers, Till On Nov 18, 2015 9:54 PM, "Truong Duc Kien" wrote: > Hi, > > I'm hitting Compiler Exception with some of my data set, but not all of > them. > > Exception in thread "main" org.apache.flink.optimizer.CompilerException: > N