Re: Error when use tow datasink

2015-05-11 Thread Robert Metzger
This looks like a dependency issue of the asm dependency. Did you upgrade all flink dependencies to the 0.8.1 version? I think you also refresh / reimport the project in your IDE so that it can pick up the new dependencies. On Mon, May 11, 2015 at 10:21 AM, hagersaleh wrote: > when upgrade from

Re: Error when use tow datasink

2015-05-11 Thread hagersaleh
when upgrade from flink 0.7.0 to 0.8.1 display error message I use netbeanse when replace lib flink 0.7.0 to to lib 0.8.1 Exception in thread "main" java.lang.NoClassDefFoundError: org/objectweb/asm/ClassVisitor at org.apache.flink.api.java.DataSet.clean(DataSet.java:133) at org.apache.fl

Re: Error when use tow datasink

2015-05-10 Thread Robert Metzger
Can you upgrade to Flink 0.8.0 ? On Sun, May 10, 2015 at 8:47 PM, hagersaleh wrote: > use flink 7.0 > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-when-use-tow-datasink-tp1205p1209.html > Sent from the Apache Flink User Mai

Re: Error when use tow datasink

2015-05-10 Thread hagersaleh
use flink 7.0 -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-when-use-tow-datasink-tp1205p1209.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Error when use tow datasink

2015-05-10 Thread Robert Metzger
Hi, which version of Flink are you using? Since 0.8.0, Flink supports disjoint dataflows ( https://issues.apache.org/jira/browse/FLINK-820). On Sun, May 10, 2015 at 6:11 PM, hagersaleh wrote: > Exception in thread "main" org.apache.flink.compiler.CompilerException: > The > given program contai