flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Build works locally but fails on travis (Storm compatibility)
Date Wed, 10 Jun 2015 12:42:19 GMT
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 <mjsax@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
>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message