[infinispan-issues] [JBoss JIRA] (ISPN-6543) Spark connector fails with CCE when compatibility mode is enabled
[
https://issues.jboss.org/browse/ISPN-6543?page=com.atlassian.jira.plugin....
]
Gustavo Fernandes edited comment on ISPN-6543 at 4/25/16 2:38 PM:
------------------------------------------------------------------
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 :/
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
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)