[infinispan-issues] [JBoss JIRA] (ISPN-6543) Spark connector fails with CCE when compatibility mode is enabled

[Gustavo Fernandes (JIRA)]

    [ https://issues.jboss.org/browse/ISPN-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13196797#comment-13196797 ] 

Gustavo Fernandes edited comment on ISPN-6543 at 4/25/16 2:38 PM:
------------------------------------------------------------------

The scala test creates dynamically the following pair cache/cache-config:
{code:xml}
<distributed-cache-configuration name="org.infinispan.spark.suites.ClusteredCompatSuite-conf" mode="SYNC" start="EAGER" statistics="true">
    <compatibility enabled="true"/>
</distributed-cache-configuration>

<distributed-cache name="org.infinispan.spark.suites.ClusteredCompatSuite" configuration="org.infinispan.spark.suites.ClusteredCompatSuite-conf"/>
{code}

And the remote iterator uses 
{code:java}
cacheManager.getCacheConfiguration(cacheName).compatibility()
{code} 

to find out if compatibility is enabled, and it returns false   :/


was (Author: gustavonalle):
The scala test created dynamically the following pair cache/cache-config:
{code:xml}
<distributed-cache-configuration name="org.infinispan.spark.suites.ClusteredCompatSuite-conf" mode="SYNC" start="EAGER" statistics="true">
    <compatibility enabled="true"/>
</distributed-cache-configuration>

<distributed-cache name="org.infinispan.spark.suites.ClusteredCompatSuite" configuration="org.infinispan.spark.suites.ClusteredCompatSuite-conf"/>
{code}

And the remote iterator uses 
{code:java}
cacheManager.getCacheConfiguration(cacheName).compatibility()
{code} 

to find out if compatibility is enabled, and it returns false   :/

> Spark connector fails with CCE when compatibility mode is enabled
> -----------------------------------------------------------------
>
>                 Key: ISPN-6543
>                 URL: https://issues.jboss.org/browse/ISPN-6543
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Spark
>            Reporter: Vojtech Juranek
>
> Fails with 
> {noformat}
> org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=125 returned server error (status=0x85): java.lang.ClassCastException: java.lang.Integer cannot be cast to [B
>         at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:343)
>         at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:132)
>         at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:118)
>         at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:56)
>         at org.infinispan.client.hotrod.impl.operations.IterationNextOperation.execute(IterationNextOperation.java:48)
>         at org.infinispan.client.hotrod.impl.iteration.RemoteCloseableIterator.fetch(RemoteCloseableIterator.java:100)
>         at org.infinispan.client.hotrod.impl.iteration.RemoteCloseableIterator.hasNext(RemoteCloseableIterator.java:84)
>         at org.infinispan.spark.rdd.InfinispanIterator.hasNext(InfinispanIterator.scala:13)
>         at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
>         at org.apache.spark.util.random.SamplingUtils$.reservoirSampleAndCount(SamplingUtils.scala:41)
>         at org.apache.spark.RangePartitioner$$anonfun$9.apply(Partitioner.scala:261)
>         at org.apache.spark.RangePartitioner$$anonfun$9.apply(Partitioner.scala:259)
>         at org.apache.spark.rdd.RDD$$anonfun$mapPartitionsWithIndex$1$$anonfun$apply$22.apply(RDD.scala:745)
>         at org.apache.spark.rdd.RDD$$anonfun$mapPartitionsWithIndex$1$$anonfun$apply$22.apply(RDD.scala:745)
>         at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)
>         at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)
>         at org.apache.spark.rdd.RDD.iterator(RDD.scala:270)
>         at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
>         at org.apache.spark.scheduler.Task.run(Task.scala:89)
>         at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:213)
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.4.11#64026)