Travis caches Maven dependendies and sometimes fails to update them. Try to clear you Travis cache via "Settings" (up right) -> "Caches"
Cheers, Fabian 2015-06-10 14:22 GMT+02:00 Matthias J. Sax <mj...@informatik.hu-berlin.de>: > 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 > > >
