[
https://issues.apache.org/jira/browse/IGNITE-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14963537#comment-14963537
]
Vasilisa Sidorova commented on IGNITE-1734:
--------------------------------------------
ScalarSnowflakeSchemaExample fails with jdkMarshaller event without remote
nodes:
{noformat}
[19:08:21,625][ERROR][main][GridDhtAtomicCache]
<ScalarSnowflakeSchemaExampleReplicated> Unexpected exception during cache
update
class org.apache.ignite.IgniteException: Failed to marshal object: DimStore
[id=-2133080274, name=Store1, zip=12345, addr=321 Chilly Dr, NY]
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl$UserCacheObjectImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:357)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:89)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry.innerUpdate(GridCacheMapEntry.java:2115)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateSingle(GridDhtAtomicCache.java:1761)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1189)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal(GridDhtAtomicCache.java:1068)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.mapSingle(GridNearAtomicUpdateFuture.java:462)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.access$1200(GridNearAtomicUpdateFuture.java:73)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$UpdateState.map(GridNearAtomicUpdateFuture.java:889)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.mapOnTopology(GridNearAtomicUpdateFuture.java:422)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.map(GridNearAtomicUpdateFuture.java:291)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$14.apply(GridDhtAtomicCache.java:844)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$14.apply(GridDhtAtomicCache.java:842)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.asyncOp(GridDhtAtomicCache.java:648)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsync0(GridDhtAtomicCache.java:842)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.putAsync0(GridDhtAtomicCache.java:381)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.putAsync(GridCacheAdapter.java:2392)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.put(GridDhtAtomicCache.java:357)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2098)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1011)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$.populateDimensions(ScalarSnowflakeSchemaExample.scala:107)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply$mcV$sp(ScalarSnowflakeSchemaExample.scala:82)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply(ScalarSnowflakeSchemaExample.scala:74)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply(ScalarSnowflakeSchemaExample.scala:74)
at org.apache.ignite.scalar.scalar$.init0(scalar.scala:181)
at org.apache.ignite.scalar.scalar$.apply(scalar.scala:237)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$.main(ScalarSnowflakeSchemaExample.scala:74)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample.main(ScalarSnowflakeSchemaExample.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to serialize
object: DimStore [id=-2133080274, name=Store1, zip=12345, addr=321 Chilly Dr,
NY]
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:82)
at
org.apache.ignite.marshaller.AbstractMarshaller.marshal(AbstractMarshaller.java:52)
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.marshal(GridCacheUtils.java:945)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl.marshal(IgniteCacheObjectProcessorImpl.java:94)
at
org.apache.ignite.internal.processors.cache.portable.CacheObjectPortableProcessorImpl.marshal(CacheObjectPortableProcessorImpl.java:717)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl$UserCacheObjectImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:342)
... 32 more
Caused by: java.io.NotSerializableException:
org.apache.ignite.scalar.examples.DimStore
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347)
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:77)
... 37 more
[19:08:21] Ignite node stopped OK [uptime=00:00:00:352]
Exception in thread "main" org.apache.ignite.cache.CachePartialUpdateException:
Failed to update keys (retry update if possible).: [-2133080274]
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1600)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.cacheException(IgniteCacheProxy.java:1744)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1018)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$.populateDimensions(ScalarSnowflakeSchemaExample.scala:107)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply$mcV$sp(ScalarSnowflakeSchemaExample.scala:82)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply(ScalarSnowflakeSchemaExample.scala:74)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$$anonfun$main$1.apply(ScalarSnowflakeSchemaExample.scala:74)
at org.apache.ignite.scalar.scalar$.init0(scalar.scala:181)
at org.apache.ignite.scalar.scalar$.apply(scalar.scala:237)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample$.main(ScalarSnowflakeSchemaExample.scala:74)
at
org.apache.ignite.scalar.examples.ScalarSnowflakeSchemaExample.main(ScalarSnowflakeSchemaExample.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Caused by: class
org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException:
Failed to update keys (retry update if possible).: [-2133080274]
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$UpdateState.addFailedKeys(GridNearAtomicUpdateFuture.java:1182)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$UpdateState.onResult(GridNearAtomicUpdateFuture.java:656)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.onResult(GridNearAtomicUpdateFuture.java:351)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$2.apply(GridNearAtomicUpdateFuture.java:465)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$2.apply(GridNearAtomicUpdateFuture.java:463)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1256)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal(GridDhtAtomicCache.java:1068)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.mapSingle(GridNearAtomicUpdateFuture.java:462)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.access$1200(GridNearAtomicUpdateFuture.java:73)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture$UpdateState.map(GridNearAtomicUpdateFuture.java:889)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.mapOnTopology(GridNearAtomicUpdateFuture.java:422)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateFuture.map(GridNearAtomicUpdateFuture.java:291)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$14.apply(GridDhtAtomicCache.java:844)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache$14.apply(GridDhtAtomicCache.java:842)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.asyncOp(GridDhtAtomicCache.java:648)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsync0(GridDhtAtomicCache.java:842)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.putAsync0(GridDhtAtomicCache.java:381)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.putAsync(GridCacheAdapter.java:2392)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.put(GridDhtAtomicCache.java:357)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2098)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.put(IgniteCacheProxy.java:1011)
... 13 more
Suppressed: class org.apache.ignite.IgniteCheckedException: Failed to
update keys on primary node.
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicUpdateResponse.addFailedKeys(GridNearAtomicUpdateResponse.java:366)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1254)
... 28 more
Suppressed: class org.apache.ignite.IgniteException: Failed to
marshal object: DimStore [id=-2133080274, name=Store1, zip=12345, addr=321
Chilly Dr, NY]
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl$UserCacheObjectImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:357)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:89)
at
org.apache.ignite.internal.processors.cache.GridCacheMapEntry.innerUpdate(GridCacheMapEntry.java:2115)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateSingle(GridDhtAtomicCache.java:1761)
at
org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridDhtAtomicCache.updateAllAsyncInternal0(GridDhtAtomicCache.java:1189)
... 28 more
Caused by: class org.apache.ignite.IgniteCheckedException:
Failed to serialize object: DimStore [id=-2133080274, name=Store1, zip=12345,
addr=321 Chilly Dr, NY]
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:82)
at
org.apache.ignite.marshaller.AbstractMarshaller.marshal(AbstractMarshaller.java:52)
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.marshal(GridCacheUtils.java:945)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl.marshal(IgniteCacheObjectProcessorImpl.java:94)
at
org.apache.ignite.internal.processors.cache.portable.CacheObjectPortableProcessorImpl.marshal(CacheObjectPortableProcessorImpl.java:717)
at
org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessorImpl$UserCacheObjectImpl.prepareForCache(IgniteCacheObjectProcessorImpl.java:342)
... 32 more
Caused by: java.io.NotSerializableException:
org.apache.ignite.scalar.examples.DimStore
at
java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183)
at
java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347)
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:77)
... 37 more
{noformat}
> ScalarCachePopularNumbersExample fails and loops when it's running with
> jdkMarshaller
> --------------------------------------------------------------------------------------
>
> Key: IGNITE-1734
> URL: https://issues.apache.org/jira/browse/IGNITE-1734
> Project: Ignite
> Issue Type: Bug
> Components: general
> Affects Versions: 1.5
> Environment: Apache Ignite build #38
> Reporter: Vasilisa Sidorova
> Fix For: 1.5
>
>
> ---------------------------------------------
> STEPS FOR REPRODUCE
> ---------------------------------------------
> # Build examples project in IDE
> # In the example-ignite.xml change property from:
> {noformat}
> <property name="marshaller">
> <bean
> class="org.apache.ignite.marshaller.optimized.OptimizedMarshaller"> -->
> <!-- Set to false to allow non-serializable objects in
> examples, default is true. -->
> <!-- <property name="requireSerializable" value="false"/>
> </bean>
> </property>
> {noformat}
> to
> {noformat}
> <property name="marshaller">
> <bean class=" org.apache.ignite.marshaller.jdk.JdkMarshaller"/>
> </property>
> {noformat}
> # Run ExampleNodeStartup
> # Run ScalarPrimeExample
> ---------------------------------------------
> ACTUAL RESULT
> ---------------------------------------------
> # Example is failed with exception:
> {noformat}
> [17:10:45,663][ERROR][main][DataStreamerImpl] Failed to marshal (request will
> not be sent).
> class org.apache.ignite.IgniteCheckedException: Failed to serialize object:
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$IncrementingUpdater@27382f59
> at
> org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:82)
> at
> org.apache.ignite.marshaller.AbstractMarshaller.marshal(AbstractMarshaller.java:52)
> at
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.submit(DataStreamerImpl.java:1279)
> at
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.update(DataStreamerImpl.java:1142)
> at
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.load0(DataStreamerImpl.java:725)
> at
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addDataInternal(DataStreamerImpl.java:547)
> at
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:583)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$$anonfun$streamData$1.apply(ScalarCachePopularNumbersExample.scala:112)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$$anonfun$streamData$1.apply(ScalarCachePopularNumbersExample.scala:112)
> at scala.collection.immutable.Range.foreach(Range.scala:160)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$.streamData(ScalarCachePopularNumbersExample.scala:112)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$$anonfun$1.apply$mcV$sp(ScalarCachePopularNumbersExample.scala:85)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$$anonfun$1.apply(ScalarCachePopularNumbersExample.scala:67)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$$anonfun$1.apply(ScalarCachePopularNumbersExample.scala:67)
> at org.apache.ignite.scalar.scalar$.init0(scalar.scala:181)
> at org.apache.ignite.scalar.scalar$.apply(scalar.scala:237)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$.delayedEndpoint$org$apache$ignite$scalar$examples$ScalarCachePopularNumbersExample$1(ScalarCachePopularNumbersExample.scala:67)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$delayedInit$body.apply(ScalarCachePopularNumbersExample.scala:48)
> at scala.Function0$class.apply$mcV$sp(Function0.scala:40)
> at
> scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
> at scala.App$$anonfun$main$1.apply(App.scala:76)
> at scala.App$$anonfun$main$1.apply(App.scala:76)
> at scala.collection.immutable.List.foreach(List.scala:381)
> at
> scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
> at scala.App$class.main(App.scala:76)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$.main(ScalarCachePopularNumbersExample.scala:48)
> at
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample.main(ScalarCachePopularNumbersExample.scala)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
> Caused by: java.io.NotSerializableException:
> org.apache.ignite.scalar.examples.ScalarCachePopularNumbersExample$IncrementingUpdater$$anon$1
> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183)
> at
> java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547)
> at
> java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508)
> at
> java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431)
> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177)
> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347)
> at
> org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal(JdkMarshaller.java:77)
> {noformat}
> # Last printed entry is looped in the example's node console
> ---------------------------------------------
> EXPECTED RESULT
> ---------------------------------------------
> Example is passed without any exceptions
> ---------------------------------------------
> ADDITIONAL INFO
> ---------------------------------------------
> # Isn't reproducible without any remote nodes
> # Isn't reproducible for the others marshallers
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
