[JBoss JIRA] (ISPN-8553) Compatibility mode not working with server tasks using Java Streams
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-8553?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes commented on ISPN-8553:
-----------------------------------------
You can try:
{code:java}
@SuppressWarnings("unchecked")
private <K, V> Cache<K, V> getCache() {
return (Cache<K, V>) ctx.getCache().get().getAdvancedCache().withEncoding(IdentityEncoder.class);
}
{code}
> Compatibility mode not working with server tasks using Java Streams
> -------------------------------------------------------------------
>
> Key: ISPN-8553
> URL: https://issues.jboss.org/browse/ISPN-8553
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2, 9.2.0.Final
>
>
> I have a cache defined as:
> {code}
> <distributed-cache name="analytics">
> <compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
> </distributed-cache>
> {code}
> Then, I have a task like this:
> {code}
> package delays.java.stream.task;
> import java.util.Arrays;
> import java.util.Calendar;
> import java.util.Collections;
> import java.util.Date;
> import java.util.Locale;
> import java.util.Map;
> import java.util.TimeZone;
> import java.util.TreeMap;
> import java.util.stream.Collector;
> import java.util.stream.Collectors;
> import org.infinispan.Cache;
> import org.infinispan.stream.CacheCollectors;
> import org.infinispan.tasks.ServerTask;
> import org.infinispan.tasks.TaskContext;
> import org.infinispan.tasks.TaskExecutionMode;
> import org.infinispan.util.function.SerializableSupplier;
> import delays.java.stream.pojos.Stop;
> public class DelayRatioTask implements ServerTask {
> private TaskContext ctx;
> @Override
> public void setTaskContext(TaskContext ctx) {
> this.ctx = ctx;
> }
> @Override
> public String getName() {
> return "delay-ratio";
> }
> @Override
> public Object call() throws Exception {
> System.out.println("Execute delay-ratio task");
> Cache<String, Stop> cache = getCache();
> Map<Integer, Long> totalPerHour = cache.values().stream()
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> Map<Integer, Long> delayedPerHour = cache.values().stream()
> .filter(e -> e.delayMin > 0)
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> return Arrays.asList(delayedPerHour, totalPerHour);
> // return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
> }
> @Override
> public TaskExecutionMode getExecutionMode() {
> return TaskExecutionMode.ONE_NODE;
> }
> @SuppressWarnings("unchecked")
> private <K, V> Cache<K, V> getCache() {
> return (Cache<K, V>) ctx.getCache().get();
> }
> private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
> return CacheCollectors.serializableCollector(s);
> }
> private static int getHourOfDay(Date date) {
> Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
> c.setTime(date);
> return c.get(Calendar.HOUR_OF_DAY);
> }
> }
> {code}
> When the groupBy executes, it fails with:
> {code}
> java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
> at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
> at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
> at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
> at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
> at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
> at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
> at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
> at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
> at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
> ... 7 more
> {code}
> This is coming from:
> {code}
> 10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
> at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
> at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
> at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
> at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
> at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
> at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
> at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
> at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
> at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
> at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
> at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
> at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-7955) Hot Rod client needs to re-resolve topology addresses after failure to connect
by Radim Vansa (JIRA)
[ https://issues.jboss.org/browse/ISPN-7955?page=com.atlassian.jira.plugin.... ]
Radim Vansa commented on ISPN-7955:
-----------------------------------
[~NadirX] I am afraid that this could lead to duplicities in connection pool: the per-server limits cannot be enforced when the address is not resolved as unresolved and resolved {{SocketAddress}} are not equal. Therefore, if client has {{localhost:11222}} in initial server list and the topology update will give you 127.0.0.1:11222 these will be considered different servers.
> Hot Rod client needs to re-resolve topology addresses after failure to connect
> ------------------------------------------------------------------------------
>
> Key: ISPN-7955
> URL: https://issues.jboss.org/browse/ISPN-7955
> Project: Infinispan
> Issue Type: Bug
> Components: Remote Protocols
> Affects Versions: 8.2.6.Final, 8.1.7.Final, 9.1.0.Beta1, 9.0.3.Final
> Reporter: Tristan Tarrant
> Assignee: Tristan Tarrant
> Fix For: 8.1.9.Final, 9.1.0.Final, 9.0.4.Final, 8.2.8.Final
>
>
> The Hot Rod client resolves topology addresses on reception. In dynamic environments where server nodes can restart with different IPs (but maintaining their external hostname) this causes the client to fail to reconnect. The client should hold on to the original address and re-resolve it in case of failures.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (IPROTO-39) ProtoSchemaGenerator fails in Karaf: CNFE: org.infinispan.protostream.RawProtobufMarshaller
by Adrian Nistor (JIRA)
Adrian Nistor created IPROTO-39:
-----------------------------------
Summary: ProtoSchemaGenerator fails in Karaf: CNFE: org.infinispan.protostream.RawProtobufMarshaller
Key: IPROTO-39
URL: https://issues.jboss.org/browse/IPROTO-39
Project: Infinispan ProtoStream
Issue Type: Bug
Affects Versions: 3.0.0.Alpha1
Reporter: Adrian Nistor
Assignee: Adrian Nistor
Fix For: 4.2.0.Alpha5, 4.1.2.Final
This was tested and fails with Karaf ver. 2.4.4, 3.0.8, 4.1.3.
This seems to be a classloading issue that is only happening when using annotation based protobuf marsahlling.
The bytecode generation that happens under the hood using javassist fails. The reason was found to be the wrong classloader used by the javassist ClassPool. Relying on the default (thread context classloader) works usually, but not in OSGi. The fix is to pass the classloader that loaded the protostream bundle to the ClassPool instead, but ClassPool's constructors do not allow that, so we need another creative solution.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (IPROTO-38) ProtoSchemaGenerator fails in Karaf: CNFE: org.infinispan.protostream.RawProtobufMarshaller
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/IPROTO-38?page=com.atlassian.jira.plugin.... ]
Adrian Nistor reopened IPROTO-38:
---------------------------------
Need to reopen this as it causes regressions in Infinispan.
It did solve the OSGi classloading issues but unfortunately it creates a new classloading issue with jboss-modules, so back to the drawing board!
> ProtoSchemaGenerator fails in Karaf: CNFE: org.infinispan.protostream.RawProtobufMarshaller
> -------------------------------------------------------------------------------------------
>
> Key: IPROTO-38
> URL: https://issues.jboss.org/browse/IPROTO-38
> Project: Infinispan ProtoStream
> Issue Type: Bug
> Affects Versions: 3.0.0.Alpha1
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Fix For: 4.2.0.Alpha5, 4.1.2.Final
>
> Attachments: stacktrace.txt
>
>
> This was tested and fails with Karaf ver. 2.4.4, 3.0.8, 4.1.3.
> This seems to be a classloading issue that is only happening when using annotation based protobuf marsahlling.
> The bytecode generation that happens under the hood using javassist fails. The reason was found to be the wrong classloader used by the javassist ClassPool. Relying on the default (thread context classloader) works usually, but not in OSGi. The fix is to pass the classloader that loaded the protostream bundle to the ClassPool instead, but ClassPool's constructors do not allow that, so we need another creative solution.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-8553) Compatibility mode not working with server tasks using Java Streams
by Galder Zamarreño (JIRA)
Galder Zamarreño created ISPN-8553:
--------------------------------------
Summary: Compatibility mode not working with server tasks using Java Streams
Key: ISPN-8553
URL: https://issues.jboss.org/browse/ISPN-8553
Project: Infinispan
Issue Type: Bug
Components: Server
Affects Versions: 9.2.0.Beta1
Reporter: Galder Zamarreño
Assignee: Gustavo Fernandes
Fix For: 9.2.0.Beta2, 9.2.0.Final
I have a cache defined as:
{code}
<distributed-cache name="analytics">
<compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
</distributed-cache>
{code}
Then, I have a task like this:
{code}
package delays.java.stream.task;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
import java.util.TreeMap;
import java.util.stream.Collector;
import java.util.stream.Collectors;
import org.infinispan.Cache;
import org.infinispan.stream.CacheCollectors;
import org.infinispan.tasks.ServerTask;
import org.infinispan.tasks.TaskContext;
import org.infinispan.tasks.TaskExecutionMode;
import org.infinispan.util.function.SerializableSupplier;
import delays.java.stream.pojos.Stop;
public class DelayRatioTask implements ServerTask {
private TaskContext ctx;
@Override
public void setTaskContext(TaskContext ctx) {
this.ctx = ctx;
}
@Override
public String getName() {
return "delay-ratio";
}
@Override
public Object call() throws Exception {
System.out.println("Execute delay-ratio task");
Cache<String, Stop> cache = getCache();
Map<Integer, Long> totalPerHour = cache.values().stream()
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
Map<Integer, Long> delayedPerHour = cache.values().stream()
.filter(e -> e.delayMin > 0)
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
return Arrays.asList(delayedPerHour, totalPerHour);
// return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
}
@Override
public TaskExecutionMode getExecutionMode() {
return TaskExecutionMode.ONE_NODE;
}
@SuppressWarnings("unchecked")
private <K, V> Cache<K, V> getCache() {
return (Cache<K, V>) ctx.getCache().get();
}
private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
return CacheCollectors.serializableCollector(s);
}
private static int getHourOfDay(Date date) {
Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
c.setTime(date);
return c.get(Calendar.HOUR_OF_DAY);
}
}
{code}
When the groupBy executes, it fails with:
{code}
java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
... 7 more
{code}
This is coming from:
{code}
10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
{code}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-8553) Compatibility mode not working with server tasks using Java Streams
by Galder Zamarreño (JIRA)
[ https://issues.jboss.org/browse/ISPN-8553?page=com.atlassian.jira.plugin.... ]
Galder Zamarreño updated ISPN-8553:
-----------------------------------
Description:
I have a cache defined as:
{code}
<distributed-cache name="analytics">
<compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
</distributed-cache>
{code}
Then, I have a task like this:
{code}
package delays.java.stream.task;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
import java.util.TreeMap;
import java.util.stream.Collector;
import java.util.stream.Collectors;
import org.infinispan.Cache;
import org.infinispan.stream.CacheCollectors;
import org.infinispan.tasks.ServerTask;
import org.infinispan.tasks.TaskContext;
import org.infinispan.tasks.TaskExecutionMode;
import org.infinispan.util.function.SerializableSupplier;
import delays.java.stream.pojos.Stop;
public class DelayRatioTask implements ServerTask {
private TaskContext ctx;
@Override
public void setTaskContext(TaskContext ctx) {
this.ctx = ctx;
}
@Override
public String getName() {
return "delay-ratio";
}
@Override
public Object call() throws Exception {
System.out.println("Execute delay-ratio task");
Cache<String, Stop> cache = getCache();
Map<Integer, Long> totalPerHour = cache.values().stream()
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
Map<Integer, Long> delayedPerHour = cache.values().stream()
.filter(e -> e.delayMin > 0)
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
return Arrays.asList(delayedPerHour, totalPerHour);
// return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
}
@Override
public TaskExecutionMode getExecutionMode() {
return TaskExecutionMode.ONE_NODE;
}
@SuppressWarnings("unchecked")
private <K, V> Cache<K, V> getCache() {
return (Cache<K, V>) ctx.getCache().get();
}
private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
return CacheCollectors.serializableCollector(s);
}
private static int getHourOfDay(Date date) {
Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
c.setTime(date);
return c.get(Calendar.HOUR_OF_DAY);
}
}
{code}
When the groupBy executes, it fails with:
{code}
java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
... 7 more
{code}
This is coming from:
{code}
10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
{code}
was:
I have a cache defined as:
{code}
<distributed-cache name="analytics">
<compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
</distributed-cache>
{code}
Then, I have a task like this:
{code}
package delays.java.stream.task;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
import java.util.TreeMap;
import java.util.stream.Collector;
import java.util.stream.Collectors;
import org.infinispan.Cache;
import org.infinispan.stream.CacheCollectors;
import org.infinispan.tasks.ServerTask;
import org.infinispan.tasks.TaskContext;
import org.infinispan.tasks.TaskExecutionMode;
import org.infinispan.util.function.SerializableSupplier;
import delays.java.stream.pojos.Stop;
public class DelayRatioTask implements ServerTask {
private TaskContext ctx;
@Override
public void setTaskContext(TaskContext ctx) {
this.ctx = ctx;
}
@Override
public String getName() {
return "delay-ratio";
}
@Override
public Object call() throws Exception {
System.out.println("Execute delay-ratio task");
Cache<String, Stop> cache = getCache();
Map<Integer, Long> totalPerHour = cache.values().stream()
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
Map<Integer, Long> delayedPerHour = cache.values().stream()
.filter(e -> e.delayMin > 0)
.collect(
serialize(() -> Collectors.groupingBy(
e -> getHourOfDay(e.departureTs),
Collectors.counting()
)));
return Arrays.asList(delayedPerHour, totalPerHour);
// return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
}
@Override
public TaskExecutionMode getExecutionMode() {
return TaskExecutionMode.ONE_NODE;
}
@SuppressWarnings("unchecked")
private <K, V> Cache<K, V> getCache() {
return (Cache<K, V>) ctx.getCache().get();
}
private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
return CacheCollectors.serializableCollector(s);
}
private static int getHourOfDay(Date date) {
Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
c.setTime(date);
return c.get(Calendar.HOUR_OF_DAY);
}
}
{code}
When the groupBy executes, it fails with:
{code}
java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
... 7 more
{code}
This is coming from:
{code}
10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
{code}
> Compatibility mode not working with server tasks using Java Streams
> -------------------------------------------------------------------
>
> Key: ISPN-8553
> URL: https://issues.jboss.org/browse/ISPN-8553
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Assignee: Gustavo Fernandes
> Fix For: 9.2.0.Beta2, 9.2.0.Final
>
>
> I have a cache defined as:
> {code}
> <distributed-cache name="analytics">
> <compatibility enabled="true" marshaller="org.infinispan.query.remote.CompatibilityProtoStreamMarshaller"/>
> </distributed-cache>
> {code}
> Then, I have a task like this:
> {code}
> package delays.java.stream.task;
> import java.util.Arrays;
> import java.util.Calendar;
> import java.util.Collections;
> import java.util.Date;
> import java.util.Locale;
> import java.util.Map;
> import java.util.TimeZone;
> import java.util.TreeMap;
> import java.util.stream.Collector;
> import java.util.stream.Collectors;
> import org.infinispan.Cache;
> import org.infinispan.stream.CacheCollectors;
> import org.infinispan.tasks.ServerTask;
> import org.infinispan.tasks.TaskContext;
> import org.infinispan.tasks.TaskExecutionMode;
> import org.infinispan.util.function.SerializableSupplier;
> import delays.java.stream.pojos.Stop;
> public class DelayRatioTask implements ServerTask {
> private TaskContext ctx;
> @Override
> public void setTaskContext(TaskContext ctx) {
> this.ctx = ctx;
> }
> @Override
> public String getName() {
> return "delay-ratio";
> }
> @Override
> public Object call() throws Exception {
> System.out.println("Execute delay-ratio task");
> Cache<String, Stop> cache = getCache();
> Map<Integer, Long> totalPerHour = cache.values().stream()
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> Map<Integer, Long> delayedPerHour = cache.values().stream()
> .filter(e -> e.delayMin > 0)
> .collect(
> serialize(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> return Arrays.asList(delayedPerHour, totalPerHour);
> // return Arrays.asList(Collections.emptyMap(), Collections.emptyMap());
> }
> @Override
> public TaskExecutionMode getExecutionMode() {
> return TaskExecutionMode.ONE_NODE;
> }
> @SuppressWarnings("unchecked")
> private <K, V> Cache<K, V> getCache() {
> return (Cache<K, V>) ctx.getCache().get();
> }
> private static <T, R> Collector<T, ?, R> serialize(SerializableSupplier<Collector<T, ?, R>> s) {
> return CacheCollectors.serializableCollector(s);
> }
> private static int getHourOfDay(Date date) {
> Calendar c = Calendar.getInstance(TimeZone.getTimeZone("GMT+1"), Locale.ENGLISH);
> c.setTime(date);
> return c.get(Calendar.HOUR_OF_DAY);
> }
> }
> {code}
> When the groupBy executes, it fails with:
> {code}
> java.lang.AssertionError: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:16)
> at delays.java.stream.AnalyticsVerticle.getDelaysRatio(AnalyticsVerticle.java:72)
> at io.vertx.ext.web.impl.BlockingHandlerDecorator.lambda$handle$0(BlockingHandlerDecorator.java:48)
> at io.vertx.core.impl.ContextImpl.lambda$executeBlocking$1(ContextImpl.java:271)
> at io.vertx.core.impl.TaskQueue.lambda$new$0(TaskQueue.java:60)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException:Request for messageId=333 returned server error (status=0x85): java.util.concurrent.ExecutionException: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at org.infinispan.client.hotrod.impl.protocol.Codec20.checkForErrorsInResponseStatus(Codec20.java:363)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readPartialHeader(Codec20.java:152)
> at org.infinispan.client.hotrod.impl.protocol.Codec20.readHeader(Codec20.java:138)
> at org.infinispan.client.hotrod.impl.operations.HotRodOperation.readHeaderAndValidate(HotRodOperation.java:60)
> at org.infinispan.client.hotrod.impl.operations.ExecuteOperation.executeOperation(ExecuteOperation.java:50)
> at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:56)
> at org.infinispan.client.hotrod.impl.RemoteCacheImpl.execute(RemoteCacheImpl.java:542)
> at delays.java.stream.AnalyticsVerticle.lambda$getDelaysRatio$1(AnalyticsVerticle.java:73)
> at delays.java.stream.AnalyticsUtil.timed(AnalyticsUtil.java:14)
> ... 7 more
> {code}
> This is coming from:
> {code}
> 10:36:18,765 WARN [org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler] (remote-thread--p2-t22) ISPN000071: Caught exception when handling command StreamRequestCommand{type=TERMINAL_REHASH, includeLoader=true, terminalOperation=org.infinispan.stream.impl.termop.SegmentRetryingOperation@1b024f9, topologyId=9, id=datagrid-1-bmspw0, segments=[128, 130, 6, 135, 137, 138, 11, 12, 140, 13, 143, 16, 144, 17, 146, 22, 152, 155, 28, 29, 31, 36, 37, 41, 42, 44, 172, 173, 177, 178, 179, 181, 183, 57, 185, 60, 61, 189, 64, 192, 65, 193, 66, 197, 201, 75, 204, 207, 80, 208, 82, 83, 84, 212, 85, 86, 89, 92, 96, 225, 98, 226, 99, 100, 101, 102, 231, 105, 233, 234, 107, 108, 237, 112, 242, 115, 246, 247, 120, 251, 124, 125, 253, 255], keys=[], excludedKeys=[]}: java.lang.ClassCastException: [B cannot be cast to delays.java.stream.pojos.Stop
> at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
> at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
> at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812)
> at org.infinispan.commons.util.Closeables$SpliteratorAsCloseableSpliterator.tryAdvance(Closeables.java:144)
> at java.util.Spliterator.forEachRemaining(Spliterator.java:326)
> at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
> at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
> at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
> at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
> at org.infinispan.stream.impl.local.LocalCacheStream.collect(LocalCacheStream.java:259)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1093)
> at org.infinispan.stream.impl.TerminalFunctions$CollectorFunction.apply(TerminalFunctions.java:1083)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.innerPerformOperation(SegmentRetryingOperation.java:68)
> at org.infinispan.stream.impl.termop.SegmentRetryingOperation.performOperation(SegmentRetryingOperation.java:79)
> at org.infinispan.stream.impl.LocalStreamManagerImpl.streamOperationRehashAware(LocalStreamManagerImpl.java:302)
> at org.infinispan.stream.impl.StreamRequestCommand.invokeAsync(StreamRequestCommand.java:96)
> at org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler.invokeCommand(BasePerCacheInboundInvocationHandler.java:102)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.invoke(BaseBlockingRunnable.java:99)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.runAsync(BaseBlockingRunnable.java:71)
> at org.infinispan.remoting.inboundhandler.BaseBlockingRunnable.run(BaseBlockingRunnable.java:40)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-8552) infinispan-bom is broken
by Galder Zamarreño (JIRA)
[ https://issues.jboss.org/browse/ISPN-8552?page=com.atlassian.jira.plugin.... ]
Galder Zamarreño edited comment on ISPN-8552 at 11/22/17 7:19 AM:
------------------------------------------------------------------
More food for thought, and the reason why I lean on the vert.x side rather than on the hibernate-ogm side:
{code}
> remerson: here's more food for thought:
> remerson: through trial/error i realised that all infinispan modules
need version info, except the protostream one...
> https://gist.github.com/galderz/85ce17dddf96b33f17e5563871bbb149
> because guess what, protostream is seen as a dependency of bom...
> not sure how you explain to the user that to the user:
> yeah, for infinispan-core do put the version info, but for
org.infinispan:protostream don't, because guess what: protostream
is different repo with different version number...
> infinispan-* 9.2.0.Beta1 works with protostream version 4.2.0.Alpha4
> so, i lean on the vert.x side
<remerson> galderz: but org.infinispan.protostream is in the bom as it
is not part of core infinispan, it has a different groupId
> slightly different group id :\
<remerson> galderz: true :)
> the user doesn't care that it's "different"
> they want to use Infinispan
<remerson> galderz: That is an interesting consideration and like you
say, that subtlety might be difficult to present to the user
> we want them to use things as easily as possible
<remerson> galderz: +1
{code}
was (Author: galder.zamarreno):
More food for thought, and the reason why I lean on the vert.x side rather than on the hibernate-ogm side:
{code}
> remerson: here's more food for thought:
> remerson: through trial/error i realised that all infinispan modules
need version info, except the protostream one...
> https://gist.github.com/galderz/85ce17dddf96b33f17e5563871bbb149
> because guess what, protostream is seen as a dependency of bom...
> not sure how you explain to the user that to the user:
> yeah, for infinispan-core do put the version info, but for
org.infinispan:protostream don't, because guess what: protostream
is different repo with different version number...
> infinispan-* 9.2.0.Beta1 works with protostream version 4.2.0.Alpha4
> so, i lean on the vert.x side
{code}
> infinispan-bom is broken
> ------------------------
>
> Key: ISPN-8552
> URL: https://issues.jboss.org/browse/ISPN-8552
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Priority: Blocker
> Fix For: 9.2.0.CR1
>
>
> I've tried to upgrade one of my examples to 9.2.0.Beta1 but it fails. I've changed version [here|https://github.com/infinispan-demos/swiss-transport-datagrid/blob/ma...] to be 9.2.0.Beta1 and I get tons of errors:
> {code}
> mvn clean package ⏎master ✭ ✱
> [INFO] Scanning for projects...
> [ERROR] [ERROR] Some problems were encountered while processing the POMs:
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> @
> [ERROR] The build could not read 3 projects -> [Help 1]
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-domain:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-domain/pom.xml) has 3 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-client:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-client/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-server:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-server/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> [ERROR]
> [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
> [ERROR] Re-run Maven using the -X switch to enable full debug logging.
> [ERROR]
> [ERROR] For more information about the errors and possible solutions, please read the following articles:
> [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ProjectBuildingException
> {code}
> This seems related to changes in ISPN-8408 where the infinispan modules disappeared from the bom (???)
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-8552) infinispan-bom is broken
by Galder Zamarreño (JIRA)
[ https://issues.jboss.org/browse/ISPN-8552?page=com.atlassian.jira.plugin.... ]
Galder Zamarreño commented on ISPN-8552:
----------------------------------------
More food for thought, and the reason why I lean on the vert.x side rather than on the hibernate-ogm side:
{code}
> remerson: here's more food for thought:
> remerson: through trial/error i realised that all infinispan modules
need version info, except the protostream one...
> https://gist.github.com/galderz/85ce17dddf96b33f17e5563871bbb149
> because guess what, protostream is seen as a dependency of bom...
> not sure how you explain to the user that to the user:
> yeah, for infinispan-core do put the version info, but for
org.infinispan:protostream don't, because guess what: protostream
is different repo with different version number...
> infinispan-* 9.2.0.Beta1 works with protostream version 4.2.0.Alpha4
> so, i lean on the vert.x side
{code}
> infinispan-bom is broken
> ------------------------
>
> Key: ISPN-8552
> URL: https://issues.jboss.org/browse/ISPN-8552
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Priority: Blocker
> Fix For: 9.2.0.CR1
>
>
> I've tried to upgrade one of my examples to 9.2.0.Beta1 but it fails. I've changed version [here|https://github.com/infinispan-demos/swiss-transport-datagrid/blob/ma...] to be 9.2.0.Beta1 and I get tons of errors:
> {code}
> mvn clean package ⏎master ✭ ✱
> [INFO] Scanning for projects...
> [ERROR] [ERROR] Some problems were encountered while processing the POMs:
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> @
> [ERROR] The build could not read 3 projects -> [Help 1]
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-domain:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-domain/pom.xml) has 3 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-client:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-client/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-server:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-server/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> [ERROR]
> [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
> [ERROR] Re-run Maven using the -X switch to enable full debug logging.
> [ERROR]
> [ERROR] For more information about the errors and possible solutions, please read the following articles:
> [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ProjectBuildingException
> {code}
> This seems related to changes in ISPN-8408 where the infinispan modules disappeared from the bom (???)
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months
[JBoss JIRA] (ISPN-8552) infinispan-bom is broken
by Galder Zamarreño (JIRA)
[ https://issues.jboss.org/browse/ISPN-8552?page=com.atlassian.jira.plugin.... ]
Galder Zamarreño edited comment on ISPN-8552 at 11/22/17 7:07 AM:
------------------------------------------------------------------
{code}
<remerson> galderz: we stripped the infinispan version stuff out of
the bom as the argument was that if you know the version of the
bom you need, you also know the version of the artifacts you need
<remerson> galderz: the idea being that the bom should just detail the
3rd party dependencies
> remerson: the whole point of the bom is that i don't need to
redefine versions of modules all around
> remerson: i disagree, see what vert.x and others do
> remerson: if you want a new bom without infinsipan modules, create a
separate bom module
<remerson> galderz: I don't have particularly strong views on this, it
was just the result of a conversation between myself, ttarrant and
sanne
<remerson> galderz: I wouldn't be against a PR that reinstates the
infinispan versions to the bom and removes them from parent
> remerson: i don't disagree wityh the motivations, but don't change
the existing bom!!
> all my examples are broken
> remerson:
https://github.com/vert-x3/vertx-dependencies/blob/master/pom.xml
...
<remerson> galderz: 5 mins and I'll issue a PR. It shouldn't be a
difficult fix
> remerson: let's have a think first
> projects like vert.x are adding their own modules to the pom.xml
> remerson: we need to study this in more detail
> remerson: as a side note, i've not heard anyone complaining about
infinispan-bom
<remerson> galderz: me neither. The motivation was to reproduce
repetition as we didn't see much benefit in having said
content. But if it is causing issues, even just with our stuff, it
is obviously worth reconsidering
<remerson> galderz: a counter example to Vert.x is hibernate-ogm
https://github.com/hibernate/hibernate-ogm/blob/master/pom.xml
> so a wider discussion is needed
> at first glance, i find it convenient to not have to define
versions...
> it's like with plugin management, you define versions and config
there, then you just use...
{code}
was (Author: galder.zamarreno):
{code}
<remerson> galderz: we stripped the infinispan version stuff out of
the bom as the argument was that if you know the version of the
bom you need, you also know the version of the artifacts you need
<remerson> galderz: the idea being that the bom should just detail the
3rd party dependencies
> remerson: the whole point of the bom is that i don't need to
redefine versions of modules all around
> remerson: i disagree, see what vert.x and others do
> remerson: if you want a new bom without infinsipan modules, create a
separate bom module
<remerson> galderz: I don't have particularly strong views on this, it
was just the result of a conversation between myself, ttarrant and
sanne
<remerson> galderz: I wouldn't be against a PR that reinstates the
infinispan versions to the bom and removes them from parent
> remerson: i don't disagree wityh the motivations, but don't change
the existing bom!!
> all my examples are broken
> remerson:
https://github.com/vert-x3/vertx-dependencies/blob/master/pom.xml
{code}
> infinispan-bom is broken
> ------------------------
>
> Key: ISPN-8552
> URL: https://issues.jboss.org/browse/ISPN-8552
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 9.2.0.Beta1
> Reporter: Galder Zamarreño
> Priority: Blocker
> Fix For: 9.2.0.CR1
>
>
> I've tried to upgrade one of my examples to 9.2.0.Beta1 but it fails. I've changed version [here|https://github.com/infinispan-demos/swiss-transport-datagrid/blob/ma...] to be 9.2.0.Beta1 and I get tons of errors:
> {code}
> mvn clean package ⏎master ✭ ✱
> [INFO] Scanning for projects...
> [ERROR] [ERROR] Some problems were encountered while processing the POMs:
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> @
> [ERROR] The build could not read 3 projects -> [Help 1]
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-domain:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-domain/pom.xml) has 3 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 23, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 29, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-core:jar is missing. @ line 41, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-client:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-client/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-client-hotrod:jar is missing. @ line 54, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-client:jar is missing. @ line 58, column 17
> [ERROR]
> [ERROR] The project swiss-transport-datagrid:analytics-server:1.0-SNAPSHOT (/Users/g/1/swiss-transport-datagrid/analytics/analytics-server/pom.xml) has 2 errors
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-tasks-api:jar is missing. @ line 30, column 17
> [ERROR] 'dependencies.dependency.version' for org.infinispan:infinispan-remote-query-server:jar is missing. @ line 36, column 17
> [ERROR]
> [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
> [ERROR] Re-run Maven using the -X switch to enable full debug logging.
> [ERROR]
> [ERROR] For more information about the errors and possible solutions, please read the following articles:
> [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ProjectBuildingException
> {code}
> This seems related to changes in ISPN-8408 where the infinispan modules disappeared from the bom (???)
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 4 months