Nevermind, I'm going to build it myself and try your patch. On Thu, Jan 29, 2015 at 4:39 PM, Arvid Heise <[email protected]> wrote:
> No I'm using the maven builds, I could try a nightly if you like. > > On Thu, Jan 29, 2015 at 4:34 PM, Aljoscha Krettek <[email protected]> > wrote: > >> Hi Arvid, >> this indeed looks like a ClassLoader problem. Are you running a >> version that you compiled yourself? If yes, could you try replacing >> line 49 in RuntimeStatefulSerializerFactory.java with this line: >> >> this.loader = Thread.currentThread().getContextClassLoader(); >> >> Cheers, >> Aljoscha >> >> On Thu, Jan 29, 2015 at 4:25 PM, Alexander Alexandrov >> <[email protected]> wrote: >> > Forget what I just said, didn't realize that it's Scala :) >> > >> > 2015-01-29 16:24 GMT+01:00 Alexander Alexandrov < >> > [email protected]>: >> > >> >> have you tried declaring your UDF classes (e.g. TotalRankDistribution) >> as >> >> static? >> >> >> >> 2015-01-29 16:14 GMT+01:00 Arvid Heise <[email protected]>: >> >> >> >>> Hi Flinker, >> >>> >> >>> I'm currently desparetely trying to get a workflow to run remotely on >> a >> >>> server. The workflow works fine in the local execution environment >> (both >> >>> with ExecutionEnvironment.getExecutionEnvironment and >> >>> ExecutionEnvironment.createLocalEnvironment(2)). >> >>> >> >>> On the server, I get >> >>> >> >>> 01/29/2015 16:05:22: GroupReduce (GroupReduce at >> >>> >> de.bund.bfr.flink.outbreakanalysis.OutbreakAnalysis$.main(OutbreakAnalysis.scala:79)) >> >>> (1/1) switched to FAILED >> >>> java.lang.RuntimeException: : Repeated instantiation of serializer >> failed. >> >>> at >> >>> >> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:340) >> >>> at >> >>> >> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:257) >> >>> at java.lang.Thread.run(Thread.java:722) >> >>> Caused by: java.lang.RuntimeException: Repeated instantiation of >> >>> serializer failed. >> >>> at >> >>> >> org.apache.flink.api.java.typeutils.runtime.RuntimeStatefulSerializerFactory.getSerializer(RuntimeStatefulSerializerFactory.java:102) >> >>> at >> >>> >> org.apache.flink.api.java.typeutils.runtime.TupleComparatorBase.instantiateDeserializationUtils(TupleComparatorBase.java:267) >> >>> at >> >>> >> org.apache.flink.api.scala.typeutils.CaseClassComparator.duplicate(CaseClassComparator.scala:42) >> >>> at >> >>> >> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.<init>(UnilateralSortMerger.java:360) >> >>> at >> >>> >> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.<init>(UnilateralSortMerger.java:227) >> >>> at >> >>> >> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.<init>(UnilateralSortMerger.java:195) >> >>> at >> >>> >> org.apache.flink.runtime.operators.RegularPactTask.initInputLocalStrategy(RegularPactTask.java:981) >> >>> at >> >>> >> org.apache.flink.runtime.operators.RegularPactTask.initLocalStrategies(RegularPactTask.java:842) >> >>> at >> >>> >> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:336) >> >>> ... 2 more >> >>> Caused by: java.lang.ClassNotFoundException: >> >>> >> de.bund.bfr.flink.outbreakanalysis.OutbreakAnalysis$$anon$13$$anon$14$$anon$15 >> >>> >> >>> The class is of course in the submitted jar and I use the same flink >> and >> >>> java version on both machines. Could it be that the wrong class >> loader is >> >>> used for duplicating the comparator? >> >>> >> >>> The code is available here >> >>> >> https://github.com/SiLeBAT/Other/tree/master/de.bund.bfr.flink.outbreakanalysis >> >>> . >> >>> If you need help to invoke the program, please msg me privately, so >> that >> >>> I can send you the non-public datasets. >> >>> >> >>> Thank you in advance, >> >>> >> >>> Arvid >> >>> >> >> >> >> >> > >
