[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:all-tabpanel ]

Work on ISPN-6543 stopped by Gustavo Fernandes.
-----------------------------------------------
> 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
>            Assignee: Gustavo Fernandes
>
> 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)