Quickfix did not help :/ Any other idea? On Thu, Jan 29, 2015 at 4:45 PM, Arvid Heise <arvid.he...@gmail.com> wrote:
> Nevermind, I'm going to build it myself and try your patch. > > On Thu, Jan 29, 2015 at 4:39 PM, Arvid Heise <arvid.he...@gmail.com> > 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 <aljos...@apache.org> >> 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 >>> <alexander.s.alexand...@gmail.com> wrote: >>> > Forget what I just said, didn't realize that it's Scala :) >>> > >>> > 2015-01-29 16:24 GMT+01:00 Alexander Alexandrov < >>> > alexander.s.alexand...@gmail.com>: >>> > >>> >> have you tried declaring your UDF classes (e.g. >>> TotalRankDistribution) as >>> >> static? >>> >> >>> >> 2015-01-29 16:14 GMT+01:00 Arvid Heise <arvid.he...@gmail.com>: >>> >> >>> >>> 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 >>> >>> >>> >> >>> >> >>> >> >> >
