You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Kottapalli, Venkatesh" <VK...@DIRECTV.com> on 2016/03/22 23:03:55 UTC
Reg IndexOutOfBoundsException while serializing the object
Hi,
I ran into the below issues while running the app today. Any inputs on why this is happening? I see this JIRA raised already but closed as "Not reproducible".
https://malhar.atlassian.net/browse/MLHR-1709
Stopped running due to an exception. java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
at java.util.ArrayList.rangeCheck(ArrayList.java:635)
at java.util.ArrayList.get(ArrayList.java:411)
at com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapReferenceResolver.java:42)
at com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
at com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1386)
Stopped running due to an exception. com.esotericsoftware.kryo.KryoException: Unable to find class:
________________________________
002950878021
at com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:138)
at com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:115)
at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
at com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
at com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1386)
Caused by: java.lang.ClassNotFoundException:
________________________________
002950878021
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:274)
at com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:136)
... 8 more
-Venkatesh.
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Timothy Farkas <ti...@datatorrent.com>.
Sure I'll pick it up.
Thanks,
Tim
On Tue, Mar 22, 2016 at 8:17 PM, Pramod Immaneni <pr...@datatorrent.com>
wrote:
> Do you want to dig into the issue Tim?
>
> On Tue, Mar 22, 2016 at 8:53 PM, Timothy Farkas <ti...@datatorrent.com>
> wrote:
>
> > This is a platform bug I encountered as well. I reported it a while ago.
> >
> > https://issues.apache.org/jira/browse/APEXCORE-316
> >
> > I believe the root cause is that when you set the stream codec on a
> stream
> > the default is only replaced for the downstream or upstream, but the
> > default stream codec continues to be used for one of the two. Haven't
> had a
> > chance to dig into the issue though.
> >
> > I agree that for most cases the DefaultStreamCodec is sufficient, but
> > things should not break if it is changed.
> >
> > Thanks,
> > Tim
> >
> > On Tue, Mar 22, 2016 at 6:37 PM, Thomas Weise <th...@datatorrent.com>
> > wrote:
> >
> > > You don't need to override the stream codec unless you want a different
> > > serialization or partitioning than what the default provides. The
> default
> > > codec uses Kryo for serialization and hashCode() for partitioning.
> > >
> > >
> > > On Tue, Mar 22, 2016 at 4:20 PM, Pramod Immaneni <
> pramod@datatorrent.com
> > >
> > > wrote:
> > >
> > > > Venkatesh,
> > > >
> > > > Any specific reason you replaced the default stream codec with
> > > > KryoSerializableStreamCodec?
> > > > Also what apex version are you using?
> > > >
> > > > Thanks
> > > >
> > > > On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh <
> > > > VKottapalli@directv.com> wrote:
> > > >
> > > > > Yes Ashwin, It has the default constructor as below.
> > > > >
> > > > > public Results() {
> > > > > super();
> > > > > }
> > > > >
> > > > > -Venkatesh.
> > > > >
> > > > > -----Original Message-----
> > > > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > > > Sent: Tuesday, March 22, 2016 4:07 PM
> > > > > To: dev@apex.incubator.apache.org
> > > > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > object
> > > > >
> > > > > For any class to be serializable by kryo, it needs to have the
> > default
> > > no
> > > > > arg constructor.
> > > > >
> > > > > Regards,
> > > > > Ashwin.
> > > > >
> > > > > On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
> > > > > VKottapalli@directv.com> wrote:
> > > > >
> > > > > > Yes Ashwin, I know the details of the class. It is a new class
> > that I
> > > > > > have added to the project. Do I have check that for anything
> > > specific
> > > > > > that might cause this issue?
> > > > > >
> > > > > > -Venkatesh.
> > > > > >
> > > > > > -----Original Message-----
> > > > > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > > > > Sent: Tuesday, March 22, 2016 3:21 PM
> > > > > > To: dev@apex.incubator.apache.org
> > > > > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > > > > > object
> > > > > >
> > > > > > Venkatesh,
> > > > > >
> > > > > > Do you know the name of the class it is not finding? Is it any
> new
> > > > > > dependency you added to the project?
> > > > > >
> > > > > > Regards,
> > > > > > Ashwin.
> > > > > >
> > > > > > On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> > > > > > VKottapalli@directv.com> wrote:
> > > > > >
> > > > > > > Hi,
> > > > > > >
> > > > > > > I ran into the below issues while running the
> app
> > > > > today.
> > > > > > > Any inputs on why this is happening? I see this JIRA raised
> > > already
> > > > > > > but closed as "Not reproducible".
> > > > > > >
> > > > > > > https://malhar.atlassian.net/browse/MLHR-1709
> > > > > > >
> > > > > > >
> > > > > > >
> > > > > > > Stopped running due to an exception.
> > > > > > > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > > > > > > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > > > > > > at java.util.ArrayList.get(ArrayList.java:411)
> > > > > > > at
> > > > > > >
> > > > > >
> > > com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> > > > > > eferenceResolver.java:42)
> > > > > > > at
> > > > > > >
> com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > > > > > > at
> > > > > > >
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > > > > > > at
> > > > > > >
> > > > > >
> > > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > > > > > yoSerializableStreamCodec.java:87)
> > > > > > > at
> > > > > > >
> > > > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > > > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > > > > at
> > > > > > >
> > > > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > > > > > eep(BufferServerSubscriber.java:316)
> > > > > > > at
> > > > > > >
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > > > > at
> > > > > > >
> > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > > > in
> > > > > > > er.java:1386)
> > > > > > >
> > > > > > >
> > > > > > > Stopped running due to an exception.
> > > > > > > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > > > > > > ________________________________
> > > > > > > 002950878021
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > > > Cl
> > > > > > > assResolver.java:138)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > > > > > > tC
> > > > > > > lassResolver.java:115)
> > > > > > >
> > > > > > > at
> > com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> > > > > > >
> > > > > > > at
> > > > > > >
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > > > > > > Kr
> > > > > > > yoSerializableStreamCodec.java:87)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > > > pr
> > > > > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > > > sw
> > > > > > > eep(BufferServerSubscriber.java:316)
> > > > > > >
> > > > > > > at
> > > > > > >
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > > > in
> > > > > > > er.java:1386)
> > > > > > >
> > > > > > > Caused by: java.lang.ClassNotFoundException:
> > > > > > > ________________________________
> > > > > > > 002950878021
> > > > > > >
> > > > > > > at
> > java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> > > > > > >
> > > > > > > at
> > java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> > > > > > >
> > > > > > > at java.security.AccessController.doPrivileged(Native
> > > > > > > Method)
> > > > > > >
> > > > > > > at
> > > > > > > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> > > > > > >
> > > > > > > at
> java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> > > > > > >
> > > > > > > at
> > > > > > > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> > > > > > >
> > > > > > > at
> java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> > > > > > >
> > > > > > > at java.lang.Class.forName0(Native Method)
> > > > > > >
> > > > > > > at java.lang.Class.forName(Class.java:274)
> > > > > > >
> > > > > > > at
> > > > > > >
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > > > Cl
> > > > > > > assResolver.java:136)
> > > > > > >
> > > > > > > ... 8 more
> > > > > > >
> > > > > > >
> > > > > > >
> > > > > > >
> > > > > > >
> > > > > > > -Venkatesh.
> > > > > > >
> > > > > > >
> > > > > >
> > > > > >
> > > > > > --
> > > > > >
> > > > > > Regards,
> > > > > > Ashwin.
> > > > > >
> > > > >
> > > > >
> > > > >
> > > > > --
> > > > >
> > > > > Regards,
> > > > > Ashwin.
> > > > >
> > > >
> > >
> >
>
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Pramod Immaneni <pr...@datatorrent.com>.
Do you want to dig into the issue Tim?
On Tue, Mar 22, 2016 at 8:53 PM, Timothy Farkas <ti...@datatorrent.com> wrote:
> This is a platform bug I encountered as well. I reported it a while ago.
>
> https://issues.apache.org/jira/browse/APEXCORE-316
>
> I believe the root cause is that when you set the stream codec on a stream
> the default is only replaced for the downstream or upstream, but the
> default stream codec continues to be used for one of the two. Haven't had a
> chance to dig into the issue though.
>
> I agree that for most cases the DefaultStreamCodec is sufficient, but
> things should not break if it is changed.
>
> Thanks,
> Tim
>
> On Tue, Mar 22, 2016 at 6:37 PM, Thomas Weise <th...@datatorrent.com>
> wrote:
>
> > You don't need to override the stream codec unless you want a different
> > serialization or partitioning than what the default provides. The default
> > codec uses Kryo for serialization and hashCode() for partitioning.
> >
> >
> > On Tue, Mar 22, 2016 at 4:20 PM, Pramod Immaneni <pramod@datatorrent.com
> >
> > wrote:
> >
> > > Venkatesh,
> > >
> > > Any specific reason you replaced the default stream codec with
> > > KryoSerializableStreamCodec?
> > > Also what apex version are you using?
> > >
> > > Thanks
> > >
> > > On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh <
> > > VKottapalli@directv.com> wrote:
> > >
> > > > Yes Ashwin, It has the default constructor as below.
> > > >
> > > > public Results() {
> > > > super();
> > > > }
> > > >
> > > > -Venkatesh.
> > > >
> > > > -----Original Message-----
> > > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > > Sent: Tuesday, March 22, 2016 4:07 PM
> > > > To: dev@apex.incubator.apache.org
> > > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> object
> > > >
> > > > For any class to be serializable by kryo, it needs to have the
> default
> > no
> > > > arg constructor.
> > > >
> > > > Regards,
> > > > Ashwin.
> > > >
> > > > On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
> > > > VKottapalli@directv.com> wrote:
> > > >
> > > > > Yes Ashwin, I know the details of the class. It is a new class
> that I
> > > > > have added to the project. Do I have check that for anything
> > specific
> > > > > that might cause this issue?
> > > > >
> > > > > -Venkatesh.
> > > > >
> > > > > -----Original Message-----
> > > > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > > > Sent: Tuesday, March 22, 2016 3:21 PM
> > > > > To: dev@apex.incubator.apache.org
> > > > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > > > > object
> > > > >
> > > > > Venkatesh,
> > > > >
> > > > > Do you know the name of the class it is not finding? Is it any new
> > > > > dependency you added to the project?
> > > > >
> > > > > Regards,
> > > > > Ashwin.
> > > > >
> > > > > On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> > > > > VKottapalli@directv.com> wrote:
> > > > >
> > > > > > Hi,
> > > > > >
> > > > > > I ran into the below issues while running the app
> > > > today.
> > > > > > Any inputs on why this is happening? I see this JIRA raised
> > already
> > > > > > but closed as "Not reproducible".
> > > > > >
> > > > > > https://malhar.atlassian.net/browse/MLHR-1709
> > > > > >
> > > > > >
> > > > > >
> > > > > > Stopped running due to an exception.
> > > > > > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > > > > > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > > > > > at java.util.ArrayList.get(ArrayList.java:411)
> > > > > > at
> > > > > >
> > > > >
> > com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> > > > > eferenceResolver.java:42)
> > > > > > at
> > > > > > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > > > > > at
> > > > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > > > > > at
> > > > > >
> > > > >
> > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > > > > yoSerializableStreamCodec.java:87)
> > > > > > at
> > > > > >
> > > > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > > > at
> > > > > >
> > > > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > > > > eep(BufferServerSubscriber.java:316)
> > > > > > at
> > > > > >
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > > > at
> > > > > >
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > > in
> > > > > > er.java:1386)
> > > > > >
> > > > > >
> > > > > > Stopped running due to an exception.
> > > > > > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > > > > > ________________________________
> > > > > > 002950878021
> > > > > >
> > > > > > at
> > > > > >
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > > Cl
> > > > > > assResolver.java:138)
> > > > > >
> > > > > > at
> > > > > >
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > > > > > tC
> > > > > > lassResolver.java:115)
> > > > > >
> > > > > > at
> com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> > > > > >
> > > > > > at
> > > > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> > > > > >
> > > > > > at
> > > > > >
> > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > > > > > Kr
> > > > > > yoSerializableStreamCodec.java:87)
> > > > > >
> > > > > > at
> > > > > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > > pr
> > > > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > > >
> > > > > > at
> > > > > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > > sw
> > > > > > eep(BufferServerSubscriber.java:316)
> > > > > >
> > > > > > at
> > > > > >
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > > >
> > > > > > at
> > > > > >
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > > in
> > > > > > er.java:1386)
> > > > > >
> > > > > > Caused by: java.lang.ClassNotFoundException:
> > > > > > ________________________________
> > > > > > 002950878021
> > > > > >
> > > > > > at
> java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> > > > > >
> > > > > > at
> java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> > > > > >
> > > > > > at java.security.AccessController.doPrivileged(Native
> > > > > > Method)
> > > > > >
> > > > > > at
> > > > > > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> > > > > >
> > > > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> > > > > >
> > > > > > at
> > > > > > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> > > > > >
> > > > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> > > > > >
> > > > > > at java.lang.Class.forName0(Native Method)
> > > > > >
> > > > > > at java.lang.Class.forName(Class.java:274)
> > > > > >
> > > > > > at
> > > > > >
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > > Cl
> > > > > > assResolver.java:136)
> > > > > >
> > > > > > ... 8 more
> > > > > >
> > > > > >
> > > > > >
> > > > > >
> > > > > >
> > > > > > -Venkatesh.
> > > > > >
> > > > > >
> > > > >
> > > > >
> > > > > --
> > > > >
> > > > > Regards,
> > > > > Ashwin.
> > > > >
> > > >
> > > >
> > > >
> > > > --
> > > >
> > > > Regards,
> > > > Ashwin.
> > > >
> > >
> >
>
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Timothy Farkas <ti...@datatorrent.com>.
This is a platform bug I encountered as well. I reported it a while ago.
https://issues.apache.org/jira/browse/APEXCORE-316
I believe the root cause is that when you set the stream codec on a stream
the default is only replaced for the downstream or upstream, but the
default stream codec continues to be used for one of the two. Haven't had a
chance to dig into the issue though.
I agree that for most cases the DefaultStreamCodec is sufficient, but
things should not break if it is changed.
Thanks,
Tim
On Tue, Mar 22, 2016 at 6:37 PM, Thomas Weise <th...@datatorrent.com>
wrote:
> You don't need to override the stream codec unless you want a different
> serialization or partitioning than what the default provides. The default
> codec uses Kryo for serialization and hashCode() for partitioning.
>
>
> On Tue, Mar 22, 2016 at 4:20 PM, Pramod Immaneni <pr...@datatorrent.com>
> wrote:
>
> > Venkatesh,
> >
> > Any specific reason you replaced the default stream codec with
> > KryoSerializableStreamCodec?
> > Also what apex version are you using?
> >
> > Thanks
> >
> > On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh <
> > VKottapalli@directv.com> wrote:
> >
> > > Yes Ashwin, It has the default constructor as below.
> > >
> > > public Results() {
> > > super();
> > > }
> > >
> > > -Venkatesh.
> > >
> > > -----Original Message-----
> > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > Sent: Tuesday, March 22, 2016 4:07 PM
> > > To: dev@apex.incubator.apache.org
> > > Subject: Re: Reg IndexOutOfBoundsException while serializing the object
> > >
> > > For any class to be serializable by kryo, it needs to have the default
> no
> > > arg constructor.
> > >
> > > Regards,
> > > Ashwin.
> > >
> > > On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
> > > VKottapalli@directv.com> wrote:
> > >
> > > > Yes Ashwin, I know the details of the class. It is a new class that I
> > > > have added to the project. Do I have check that for anything
> specific
> > > > that might cause this issue?
> > > >
> > > > -Venkatesh.
> > > >
> > > > -----Original Message-----
> > > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > > Sent: Tuesday, March 22, 2016 3:21 PM
> > > > To: dev@apex.incubator.apache.org
> > > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > > > object
> > > >
> > > > Venkatesh,
> > > >
> > > > Do you know the name of the class it is not finding? Is it any new
> > > > dependency you added to the project?
> > > >
> > > > Regards,
> > > > Ashwin.
> > > >
> > > > On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> > > > VKottapalli@directv.com> wrote:
> > > >
> > > > > Hi,
> > > > >
> > > > > I ran into the below issues while running the app
> > > today.
> > > > > Any inputs on why this is happening? I see this JIRA raised
> already
> > > > > but closed as "Not reproducible".
> > > > >
> > > > > https://malhar.atlassian.net/browse/MLHR-1709
> > > > >
> > > > >
> > > > >
> > > > > Stopped running due to an exception.
> > > > > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > > > > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > > > > at java.util.ArrayList.get(ArrayList.java:411)
> > > > > at
> > > > >
> > > >
> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> > > > eferenceResolver.java:42)
> > > > > at
> > > > > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > > > > at
> > > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > > > > at
> > > > >
> > > >
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > > > yoSerializableStreamCodec.java:87)
> > > > > at
> > > > >
> > > >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > > at
> > > > >
> > > >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > > > eep(BufferServerSubscriber.java:316)
> > > > > at
> > > > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > > at
> > > > >
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > in
> > > > > er.java:1386)
> > > > >
> > > > >
> > > > > Stopped running due to an exception.
> > > > > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > > > > ________________________________
> > > > > 002950878021
> > > > >
> > > > > at
> > > > >
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > Cl
> > > > > assResolver.java:138)
> > > > >
> > > > > at
> > > > >
> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > > > > tC
> > > > > lassResolver.java:115)
> > > > >
> > > > > at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> > > > >
> > > > > at
> > > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> > > > >
> > > > > at
> > > > >
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > > > > Kr
> > > > > yoSerializableStreamCodec.java:87)
> > > > >
> > > > > at
> > > > >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > pr
> > > > > ocessPayload(BufferServerSubscriber.java:361)
> > > > >
> > > > > at
> > > > >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > > sw
> > > > > eep(BufferServerSubscriber.java:316)
> > > > >
> > > > > at
> > > > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > >
> > > > > at
> > > > >
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > > in
> > > > > er.java:1386)
> > > > >
> > > > > Caused by: java.lang.ClassNotFoundException:
> > > > > ________________________________
> > > > > 002950878021
> > > > >
> > > > > at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> > > > >
> > > > > at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> > > > >
> > > > > at java.security.AccessController.doPrivileged(Native
> > > > > Method)
> > > > >
> > > > > at
> > > > > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> > > > >
> > > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> > > > >
> > > > > at
> > > > > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> > > > >
> > > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> > > > >
> > > > > at java.lang.Class.forName0(Native Method)
> > > > >
> > > > > at java.lang.Class.forName(Class.java:274)
> > > > >
> > > > > at
> > > > >
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > > Cl
> > > > > assResolver.java:136)
> > > > >
> > > > > ... 8 more
> > > > >
> > > > >
> > > > >
> > > > >
> > > > >
> > > > > -Venkatesh.
> > > > >
> > > > >
> > > >
> > > >
> > > > --
> > > >
> > > > Regards,
> > > > Ashwin.
> > > >
> > >
> > >
> > >
> > > --
> > >
> > > Regards,
> > > Ashwin.
> > >
> >
>
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Thomas Weise <th...@datatorrent.com>.
You don't need to override the stream codec unless you want a different
serialization or partitioning than what the default provides. The default
codec uses Kryo for serialization and hashCode() for partitioning.
On Tue, Mar 22, 2016 at 4:20 PM, Pramod Immaneni <pr...@datatorrent.com>
wrote:
> Venkatesh,
>
> Any specific reason you replaced the default stream codec with
> KryoSerializableStreamCodec?
> Also what apex version are you using?
>
> Thanks
>
> On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh <
> VKottapalli@directv.com> wrote:
>
> > Yes Ashwin, It has the default constructor as below.
> >
> > public Results() {
> > super();
> > }
> >
> > -Venkatesh.
> >
> > -----Original Message-----
> > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > Sent: Tuesday, March 22, 2016 4:07 PM
> > To: dev@apex.incubator.apache.org
> > Subject: Re: Reg IndexOutOfBoundsException while serializing the object
> >
> > For any class to be serializable by kryo, it needs to have the default no
> > arg constructor.
> >
> > Regards,
> > Ashwin.
> >
> > On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
> > VKottapalli@directv.com> wrote:
> >
> > > Yes Ashwin, I know the details of the class. It is a new class that I
> > > have added to the project. Do I have check that for anything specific
> > > that might cause this issue?
> > >
> > > -Venkatesh.
> > >
> > > -----Original Message-----
> > > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > > Sent: Tuesday, March 22, 2016 3:21 PM
> > > To: dev@apex.incubator.apache.org
> > > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > > object
> > >
> > > Venkatesh,
> > >
> > > Do you know the name of the class it is not finding? Is it any new
> > > dependency you added to the project?
> > >
> > > Regards,
> > > Ashwin.
> > >
> > > On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> > > VKottapalli@directv.com> wrote:
> > >
> > > > Hi,
> > > >
> > > > I ran into the below issues while running the app
> > today.
> > > > Any inputs on why this is happening? I see this JIRA raised already
> > > > but closed as "Not reproducible".
> > > >
> > > > https://malhar.atlassian.net/browse/MLHR-1709
> > > >
> > > >
> > > >
> > > > Stopped running due to an exception.
> > > > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > > > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > > > at java.util.ArrayList.get(ArrayList.java:411)
> > > > at
> > > >
> > > com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> > > eferenceResolver.java:42)
> > > > at
> > > > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > > > at
> > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > > > at
> > > >
> > > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > > yoSerializableStreamCodec.java:87)
> > > > at
> > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > > ocessPayload(BufferServerSubscriber.java:361)
> > > > at
> > > >
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > > eep(BufferServerSubscriber.java:316)
> > > > at
> > > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > > at
> > > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > in
> > > > er.java:1386)
> > > >
> > > >
> > > > Stopped running due to an exception.
> > > > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > > > ________________________________
> > > > 002950878021
> > > >
> > > > at
> > > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > Cl
> > > > assResolver.java:138)
> > > >
> > > > at
> > > > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > > > tC
> > > > lassResolver.java:115)
> > > >
> > > > at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> > > >
> > > > at
> > > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> > > >
> > > > at
> > > > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > > > Kr
> > > > yoSerializableStreamCodec.java:87)
> > > >
> > > > at
> > > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > pr
> > > > ocessPayload(BufferServerSubscriber.java:361)
> > > >
> > > > at
> > > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > > sw
> > > > eep(BufferServerSubscriber.java:316)
> > > >
> > > > at
> > > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > >
> > > > at
> > > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > > in
> > > > er.java:1386)
> > > >
> > > > Caused by: java.lang.ClassNotFoundException:
> > > > ________________________________
> > > > 002950878021
> > > >
> > > > at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> > > >
> > > > at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> > > >
> > > > at java.security.AccessController.doPrivileged(Native
> > > > Method)
> > > >
> > > > at
> > > > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> > > >
> > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> > > >
> > > > at
> > > > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> > > >
> > > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> > > >
> > > > at java.lang.Class.forName0(Native Method)
> > > >
> > > > at java.lang.Class.forName(Class.java:274)
> > > >
> > > > at
> > > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > > Cl
> > > > assResolver.java:136)
> > > >
> > > > ... 8 more
> > > >
> > > >
> > > >
> > > >
> > > >
> > > > -Venkatesh.
> > > >
> > > >
> > >
> > >
> > > --
> > >
> > > Regards,
> > > Ashwin.
> > >
> >
> >
> >
> > --
> >
> > Regards,
> > Ashwin.
> >
>
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Pramod Immaneni <pr...@datatorrent.com>.
Venkatesh,
Any specific reason you replaced the default stream codec with
KryoSerializableStreamCodec?
Also what apex version are you using?
Thanks
On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh <
VKottapalli@directv.com> wrote:
> Yes Ashwin, It has the default constructor as below.
>
> public Results() {
> super();
> }
>
> -Venkatesh.
>
> -----Original Message-----
> From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> Sent: Tuesday, March 22, 2016 4:07 PM
> To: dev@apex.incubator.apache.org
> Subject: Re: Reg IndexOutOfBoundsException while serializing the object
>
> For any class to be serializable by kryo, it needs to have the default no
> arg constructor.
>
> Regards,
> Ashwin.
>
> On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
> VKottapalli@directv.com> wrote:
>
> > Yes Ashwin, I know the details of the class. It is a new class that I
> > have added to the project. Do I have check that for anything specific
> > that might cause this issue?
> >
> > -Venkatesh.
> >
> > -----Original Message-----
> > From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> > Sent: Tuesday, March 22, 2016 3:21 PM
> > To: dev@apex.incubator.apache.org
> > Subject: Re: Reg IndexOutOfBoundsException while serializing the
> > object
> >
> > Venkatesh,
> >
> > Do you know the name of the class it is not finding? Is it any new
> > dependency you added to the project?
> >
> > Regards,
> > Ashwin.
> >
> > On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> > VKottapalli@directv.com> wrote:
> >
> > > Hi,
> > >
> > > I ran into the below issues while running the app
> today.
> > > Any inputs on why this is happening? I see this JIRA raised already
> > > but closed as "Not reproducible".
> > >
> > > https://malhar.atlassian.net/browse/MLHR-1709
> > >
> > >
> > >
> > > Stopped running due to an exception.
> > > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > > at java.util.ArrayList.get(ArrayList.java:411)
> > > at
> > >
> > com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> > eferenceResolver.java:42)
> > > at
> > > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > > at
> > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > > at
> > >
> > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > yoSerializableStreamCodec.java:87)
> > > at
> > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > ocessPayload(BufferServerSubscriber.java:361)
> > > at
> > >
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > eep(BufferServerSubscriber.java:316)
> > > at
> > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > > at
> > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > in
> > > er.java:1386)
> > >
> > >
> > > Stopped running due to an exception.
> > > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > > ________________________________
> > > 002950878021
> > >
> > > at
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > Cl
> > > assResolver.java:138)
> > >
> > > at
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > > tC
> > > lassResolver.java:115)
> > >
> > > at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> > >
> > > at
> > > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> > >
> > > at
> > > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > > Kr
> > > yoSerializableStreamCodec.java:87)
> > >
> > > at
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > pr
> > > ocessPayload(BufferServerSubscriber.java:361)
> > >
> > > at
> > > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > > sw
> > > eep(BufferServerSubscriber.java:316)
> > >
> > > at
> > > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > >
> > > at
> > > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > > in
> > > er.java:1386)
> > >
> > > Caused by: java.lang.ClassNotFoundException:
> > > ________________________________
> > > 002950878021
> > >
> > > at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> > >
> > > at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> > >
> > > at java.security.AccessController.doPrivileged(Native
> > > Method)
> > >
> > > at
> > > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> > >
> > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> > >
> > > at
> > > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> > >
> > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> > >
> > > at java.lang.Class.forName0(Native Method)
> > >
> > > at java.lang.Class.forName(Class.java:274)
> > >
> > > at
> > > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > > Cl
> > > assResolver.java:136)
> > >
> > > ... 8 more
> > >
> > >
> > >
> > >
> > >
> > > -Venkatesh.
> > >
> > >
> >
> >
> > --
> >
> > Regards,
> > Ashwin.
> >
>
>
>
> --
>
> Regards,
> Ashwin.
>
RE: Reg IndexOutOfBoundsException while serializing the object
Posted by "Kottapalli, Venkatesh" <VK...@DIRECTV.com>.
Yes Ashwin, It has the default constructor as below.
public Results() {
super();
}
-Venkatesh.
-----Original Message-----
From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
Sent: Tuesday, March 22, 2016 4:07 PM
To: dev@apex.incubator.apache.org
Subject: Re: Reg IndexOutOfBoundsException while serializing the object
For any class to be serializable by kryo, it needs to have the default no arg constructor.
Regards,
Ashwin.
On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh < VKottapalli@directv.com> wrote:
> Yes Ashwin, I know the details of the class. It is a new class that I
> have added to the project. Do I have check that for anything specific
> that might cause this issue?
>
> -Venkatesh.
>
> -----Original Message-----
> From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> Sent: Tuesday, March 22, 2016 3:21 PM
> To: dev@apex.incubator.apache.org
> Subject: Re: Reg IndexOutOfBoundsException while serializing the
> object
>
> Venkatesh,
>
> Do you know the name of the class it is not finding? Is it any new
> dependency you added to the project?
>
> Regards,
> Ashwin.
>
> On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> VKottapalli@directv.com> wrote:
>
> > Hi,
> >
> > I ran into the below issues while running the app today.
> > Any inputs on why this is happening? I see this JIRA raised already
> > but closed as "Not reproducible".
> >
> > https://malhar.atlassian.net/browse/MLHR-1709
> >
> >
> >
> > Stopped running due to an exception.
> > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > at java.util.ArrayList.get(ArrayList.java:411)
> > at
> >
> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapR
> eferenceResolver.java:42)
> > at
> > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > at
> > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > at
> >
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> yoSerializableStreamCodec.java:87)
> > at
> >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> ocessPayload(BufferServerSubscriber.java:361)
> > at
> >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> eep(BufferServerSubscriber.java:316)
> > at
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > at
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > in
> > er.java:1386)
> >
> >
> > Stopped running due to an exception.
> > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > ________________________________
> > 002950878021
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > Cl
> > assResolver.java:138)
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(Defaul
> > tC
> > lassResolver.java:115)
> >
> > at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> >
> > at
> > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> >
> > at
> > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(
> > Kr
> > yoSerializableStreamCodec.java:87)
> >
> > at
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > pr
> > ocessPayload(BufferServerSubscriber.java:361)
> >
> > at
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.
> > sw
> > eep(BufferServerSubscriber.java:316)
> >
> > at
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> >
> > at
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingConta
> > in
> > er.java:1386)
> >
> > Caused by: java.lang.ClassNotFoundException:
> > ________________________________
> > 002950878021
> >
> > at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> >
> > at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> >
> > at java.security.AccessController.doPrivileged(Native
> > Method)
> >
> > at
> > java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> >
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> >
> > at
> > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> >
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> >
> > at java.lang.Class.forName0(Native Method)
> >
> > at java.lang.Class.forName(Class.java:274)
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(Default
> > Cl
> > assResolver.java:136)
> >
> > ... 8 more
> >
> >
> >
> >
> >
> > -Venkatesh.
> >
> >
>
>
> --
>
> Regards,
> Ashwin.
>
--
Regards,
Ashwin.
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Ashwin Chandra Putta <as...@gmail.com>.
For any class to be serializable by kryo, it needs to have the default no
arg constructor.
Regards,
Ashwin.
On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh <
VKottapalli@directv.com> wrote:
> Yes Ashwin, I know the details of the class. It is a new class that I have
> added to the project. Do I have check that for anything specific that
> might cause this issue?
>
> -Venkatesh.
>
> -----Original Message-----
> From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
> Sent: Tuesday, March 22, 2016 3:21 PM
> To: dev@apex.incubator.apache.org
> Subject: Re: Reg IndexOutOfBoundsException while serializing the object
>
> Venkatesh,
>
> Do you know the name of the class it is not finding? Is it any new
> dependency you added to the project?
>
> Regards,
> Ashwin.
>
> On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
> VKottapalli@directv.com> wrote:
>
> > Hi,
> >
> > I ran into the below issues while running the app today.
> > Any inputs on why this is happening? I see this JIRA raised already
> > but closed as "Not reproducible".
> >
> > https://malhar.atlassian.net/browse/MLHR-1709
> >
> >
> >
> > Stopped running due to an exception.
> > java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> > at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> > at java.util.ArrayList.get(ArrayList.java:411)
> > at
> >
> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapReferenceResolver.java:42)
> > at
> > com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> > at
> > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> > at
> >
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
> > at
> >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
> > at
> >
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
> > at
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> > at
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContain
> > er.java:1386)
> >
> >
> > Stopped running due to an exception.
> > com.esotericsoftware.kryo.KryoException: Unable to find class:
> > ________________________________
> > 002950878021
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultCl
> > assResolver.java:138)
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultC
> > lassResolver.java:115)
> >
> > at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> >
> > at
> > com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> >
> > at
> > com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> > yoSerializableStreamCodec.java:87)
> >
> > at
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> > ocessPayload(BufferServerSubscriber.java:361)
> >
> > at
> > com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> > eep(BufferServerSubscriber.java:316)
> >
> > at
> > com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> >
> > at
> > com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContain
> > er.java:1386)
> >
> > Caused by: java.lang.ClassNotFoundException:
> > ________________________________
> > 002950878021
> >
> > at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> >
> > at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> >
> > at java.security.AccessController.doPrivileged(Native Method)
> >
> > at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> >
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> >
> > at
> > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> >
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> >
> > at java.lang.Class.forName0(Native Method)
> >
> > at java.lang.Class.forName(Class.java:274)
> >
> > at
> > com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultCl
> > assResolver.java:136)
> >
> > ... 8 more
> >
> >
> >
> >
> >
> > -Venkatesh.
> >
> >
>
>
> --
>
> Regards,
> Ashwin.
>
--
Regards,
Ashwin.
RE: Reg IndexOutOfBoundsException while serializing the object
Posted by "Kottapalli, Venkatesh" <VK...@DIRECTV.com>.
Yes Ashwin, I know the details of the class. It is a new class that I have added to the project. Do I have check that for anything specific that might cause this issue?
-Venkatesh.
-----Original Message-----
From: Ashwin Chandra Putta [mailto:ashwinchandrap@gmail.com]
Sent: Tuesday, March 22, 2016 3:21 PM
To: dev@apex.incubator.apache.org
Subject: Re: Reg IndexOutOfBoundsException while serializing the object
Venkatesh,
Do you know the name of the class it is not finding? Is it any new dependency you added to the project?
Regards,
Ashwin.
On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh < VKottapalli@directv.com> wrote:
> Hi,
>
> I ran into the below issues while running the app today.
> Any inputs on why this is happening? I see this JIRA raised already
> but closed as "Not reproducible".
>
> https://malhar.atlassian.net/browse/MLHR-1709
>
>
>
> Stopped running due to an exception.
> java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> at java.util.ArrayList.get(ArrayList.java:411)
> at
> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapReferenceResolver.java:42)
> at
> com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> at
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> at
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
> at
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> at
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContain
> er.java:1386)
>
>
> Stopped running due to an exception.
> com.esotericsoftware.kryo.KryoException: Unable to find class:
> ________________________________
> 002950878021
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultCl
> assResolver.java:138)
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultC
> lassResolver.java:115)
>
> at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
>
> at
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
>
> at
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(Kr
> yoSerializableStreamCodec.java:87)
>
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.pr
> ocessPayload(BufferServerSubscriber.java:361)
>
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sw
> eep(BufferServerSubscriber.java:316)
>
> at
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
>
> at
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContain
> er.java:1386)
>
> Caused by: java.lang.ClassNotFoundException:
> ________________________________
> 002950878021
>
> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>
> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>
> at java.security.AccessController.doPrivileged(Native Method)
>
> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>
> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>
> at
> sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
>
> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>
> at java.lang.Class.forName0(Native Method)
>
> at java.lang.Class.forName(Class.java:274)
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultCl
> assResolver.java:136)
>
> ... 8 more
>
>
>
>
>
> -Venkatesh.
>
>
--
Regards,
Ashwin.
Re: Reg IndexOutOfBoundsException while serializing the object
Posted by Ashwin Chandra Putta <as...@gmail.com>.
Venkatesh,
Do you know the name of the class it is not finding? Is it any new
dependency you added to the project?
Regards,
Ashwin.
On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh <
VKottapalli@directv.com> wrote:
> Hi,
>
> I ran into the below issues while running the app today.
> Any inputs on why this is happening? I see this JIRA raised already but
> closed as "Not reproducible".
>
> https://malhar.atlassian.net/browse/MLHR-1709
>
>
>
> Stopped running due to an exception.
> java.lang.IndexOutOfBoundsException: Index: 97, Size: 45
> at java.util.ArrayList.rangeCheck(ArrayList.java:635)
> at java.util.ArrayList.get(ArrayList.java:411)
> at
> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapReferenceResolver.java:42)
> at
> com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805)
> at
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:759)
> at
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
> at
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
> at
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1386)
>
>
> Stopped running due to an exception.
> com.esotericsoftware.kryo.KryoException: Unable to find class:
> ________________________________
> 002950878021
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:138)
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:115)
>
> at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
>
> at
> com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
>
> at
> com.datatorrent.lib.codec.KryoSerializableStreamCodec.fromByteArray(KryoSerializableStreamCodec.java:87)
>
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.processPayload(BufferServerSubscriber.java:361)
>
> at
> com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:316)
>
> at
> com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:229)
>
> at
> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1386)
>
> Caused by: java.lang.ClassNotFoundException:
> ________________________________
> 002950878021
>
> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>
> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>
> at java.security.AccessController.doPrivileged(Native Method)
>
> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>
> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
>
> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>
> at java.lang.Class.forName0(Native Method)
>
> at java.lang.Class.forName(Class.java:274)
>
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:136)
>
> ... 8 more
>
>
>
>
>
> -Venkatesh.
>
>
--
Regards,
Ashwin.