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
signature.asc
Description: OpenPGP digital signature
