Re: AW: kryoException : Buffer underflow

__ > Von: Timo Walther > Gesendet: Mittwoch, 11. Februar 2015 21:55 > An: dev@flink.apache.org > Betreff: Re: kryoException : Buffer underflow > > @Stephan: Yes you are correct. Both omitting the "returns(...)" > statement, or changing it to &

Re: AW: kryoException : Buffer underflow

xt call .. Johannes Von: Timo Walther Gesendet: Mittwoch, 11. Februar 2015 21:55 An: dev@flink.apache.org Betreff: Re: kryoException : Buffer underflow @Stephan: Yes you are correct. Both omitting the "returns(...)" statement, or changing it to "returns(Centroid

AW: kryoException : Buffer underflow

buffer underflow. So somewhere there should be a hasNext call .. Johannes Von: Timo Walther Gesendet: Mittwoch, 11. Februar 2015 21:55 An: dev@flink.apache.org Betreff: Re: kryoException : Buffer underflow @Stephan: Yes you are correct. Both omitting the "re

Re: kryoException : Buffer underflow

JoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker( ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run( ForkJoinWorkerThread.java:107) The centroid25 data is exactly the same in both cases. Could you help me ret

Re: kryoException : Buffer underflow

n(DoTheKMeans.java:71))(1/1) switched to CANCELING > > >>> 02/11/2015 14:58:27 DataSink(Print to System.out)(1/1) > > >>> > > >> switched to > > >> > > >>> CANCELED > > >>> 02/11/2015 14:58:27 Sync(BulkIterat

Re: kryoException : Buffer underflow

Map > >>> (Map at main(DoTheKMeans.java:71))(1/1) switched to CANCELED > >>> 02/11/2015 14:58:27 Job execution switched to status FAILED. > >>> Exception in thread "main" > >>> org.apache.flink.runtime.client.JobExecutionException: > >>> com.esotericsoftware.kryo.KryoException: Buffer underflow > >>> at > >>> > >>> > >>> org.apache.flink.api.java.typeutils.runtime.NoFetchingInput.require( > >> NoFetchingInput.java:76) > >> > >>> at > >>> > >> com.esotericsoftware.kryo.io.Input.readVarInt(Input.java:355) > >> > >>> at > >>> > >>> > >>> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass( > >> DefaultClassResolver.java:109) > >> > >>> at > >>> > >> com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641) > >> > >>> at > >>> > >> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752) > >> > >>> at > >>> > >>> > >>> > org.apache.flink.api.java.typeutils.runtime.KryoSerializer.deserialize( > >> KryoSerializer.java:205) > >> > >>> at > >>> > >>> > >>> > org.apache.flink.api.java.typeutils.runtime.KryoSerializer.deserialize( > >> KryoSerializer.java:210) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.io.disk.InputViewIterator.next( > >> InputViewIterator.java:43) > >> > >>> at > >>> > >>> org.apache.flink.runtime.operators.NoOpDriver.run(NoOpDriver.java:91) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.operators.RegularPactTask.run( > >> RegularPactTask.java:496) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.iterative.task.AbstractIterativePactTask.run( > >> AbstractIterativePactTask.java:138) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.iterative.task.IterationHeadPactTask.run( > >> IterationHeadPactTask.java:324) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.operators.RegularPactTask. > >> invoke(RegularPactTask.java:360) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.execution.RuntimeEnvironment. > >> run(RuntimeEnvironment.java:204) > >> > >>> at java.lang.Thread.run(Thread.java:745) > >>> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.client.JobClientListener$$anonfun$ > >> receiveWithLogMessages$2.applyOrElse(JobClient.scala:88) > >> > >>> at > >>> > >>> > >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp( > >> AbstractPartialFunction.scala:33) > >> > >>> at > >>> > >>> > >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply( > >> AbstractPartialFunction.scala:33) > >> > >>> at > >>> > >>> > >>> scala.runtime.AbstractPartialFunction$mcVL$sp.apply( > >> AbstractPartialFunction.scala:25) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.ActorLogMessages$$anon$1. > >> apply(ActorLogMessages.scala:37) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.ActorLogMessages$$anon$1. > >> apply(ActorLogMessages.scala:30) > >> > >>> at > >>> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118) > >>> at > >>> > >>> > >>> org.apache.flink.runtime.ActorLogMessages$$anon$1. > >> applyOrElse(ActorLogMessages.scala:30) > >> > >>> at > >>> > >> akka.actor.Actor$class.aroundReceive(Actor.scala:465) > >> > >>> at > >>> > >>> > >>> org.apache.flink.runtime.client.JobClientListener. > >> aroundReceive(JobClient.scala:74) > >> > >>> at > >>> > >> akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) > >> > >>> at akka.actor.ActorCell.invoke(ActorCell.scala:487) > >>> at > >>> > >> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) > >> > >>> at akka.dispatch.Mailbox.run(Mailbox.scala:221) > >>> at akka.dispatch.Mailbox.exec(Mailbox.scala:231) > >>> at > >>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > >>> at > >>> > >>> > >>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue. > >> runTask(ForkJoinPool.java:1339) > >> > >>> at > >>> > >>> scala.concurrent.forkjoin.ForkJoinPool.runWorker( > >> ForkJoinPool.java:1979) > >> > >>> at > >>> > >>> > >>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run( > >> ForkJoinWorkerThread.java:107) > >> > >>> The centroid25 data is exactly the same in both cases. Could you > >>> > >> help me > >> > >>> retrace what is wrong? > >>> > >>> Thanks and best regards, > >>> > >>> Tran Nam-Luc > >>> > >>> > >>> > >>> -- > >>> View this message in context: > >>> > >>> http://apache-flink-incubator-mailing-list-archive.1008284. > >> n3.nabble.com/kryoException-Buffer-underflow-tp3760.html > >> > >>> Sent from the Apache Flink (Incubator) Mailing List archive. mailing > >>> > >> list > >> > >>> archive at Nabble.com. > >>> > >>> > >> > >> > > >

Re: kryoException : Buffer underflow

lver.java:109) >> >>> at >>> >> com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641) >> >>> at >>> >> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752) >> >>> at >>> >

Re: kryoException : Buffer underflow

cases. Could you help me retrace what is wrong? Thanks and best regards, Tran Nam-Luc -- View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/kryoException-Buffer-underflow-tp3760.html Sent from the Apache Flink (Incubator) Mailing List archive. mailing list archive at Nabble.com.

Re: kryoException : Buffer underflow

.actor.ActorCell.invoke(ActorCell.scala:487) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) > at akka.dispatch.Mailbox.run(Mailbox.scala:221) > at akka.dispatch.Mailbox.exec(Mailbox.scala:231) >     at > scala.concurrent.forkjoin.ForkJoinTa

Re: kryoException : Buffer underflow

.scala:254) > at akka.dispatch.Mailbox.run(Mailbox.scala:221) > at akka.dispatch.Mailbox.exec(Mailbox.scala:231) > at > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > The centroid25 data is exactly the same in both cases. Could you help me > retrace what is wrong? > > Thanks and best regards, > > Tran Nam-Luc > > > > -- > View this message in context: > http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/kryoException-Buffer-underflow-tp3760.html > Sent from the Apache Flink (Incubator) Mailing List archive. mailing list > archive at Nabble.com. >

kryoException : Buffer underflow

text: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/kryoException-Buffer-underflow-tp3760.html Sent from the Apache Flink (Incubator) Mailing List archive. mailing list archive at Nabble.com.