This seems like a version mismatch. For example, DataStream.distribute() was changed to DataStream.rebalance() recently. Maybe your build getting some outdated jars from the travis cache.
On Wed, Jun 10, 2015 at 2:22 PM, Matthias J. Sax <mj...@informatik.hu-berlin.de> wrote: > Hi, > > the current PR of storm compatibility layer builds successfully on my > laptop (mvn clean install). However, on travis I get strange error > messages in the IT-Cases: > https://travis-ci.org/mjsax/flink/builds/66137928 > > For example: > >> Caused by: java.lang.AbstractMethodError: >> org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapper.run(Lorg/apache/flink/streaming/api/functions/source/SourceFunction$SourceContext;)V >> at >> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:49) >> at >> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.invoke(SourceStreamTask.java:55) >> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) >> at java.lang.Thread.run(Thread.java:701) > > and > >> java.lang.NoSuchMethodError: >> org.apache.flink.streaming.api.datastream.DataStream.distribute()Lorg/apache/flink/streaming/api/datastream/DataStream; >> at >> org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder.createTopology(FlinkTopologyBuilder.java:155) >> at >> org.apache.flink.stormcompatibility.wordcount.StormWordCountLocal.main(StormWordCountLocal.java:66) >> at >> org.apache.flink.stormcompatibility.wordcount.StormWordCountLocalITCase.testProgram(StormWordCountLocalITCase.java:45) > > Looking into the code the method "run(...)" is implemented in > AbstractStormSpoutWrapper.java what is the base class of > StormFiniteSpoutWrapper.java. So I cannot explain this error... > > see: >> https://github.com/mjsax/flink/blob/18a3c8b79c5f353bbfd65370811e900edc7abc89/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormFiniteSpoutWrapper.java >> https://github.com/mjsax/flink/blob/18a3c8b79c5f353bbfd65370811e900edc7abc89/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormSpoutWrapper.java > > Furthermore, the method "distribute()" was used in an old version of the > layer, but got replaces by "shuffle()". Thus, I don't understand the > second error message either... > > see: >> https://github.com/mjsax/flink/blob/18a3c8b79c5f353bbfd65370811e900edc7abc89/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopologyBuilder.java > > Something must be wrong with travis. It seems not to work on the correct > code. However, I have no idea why... Maybe some version mixup. > > And ideas how I can fix this? > > > -Matthias > >
