Aurélien Pupier created CAMEL-25344:
---------------------------------------

             Summary: [T1C] InfinispanRemoteQueryProducerIT and 
InfinispanRemoteQueryConsumerIT are failing most of the times when full build 
launched with -T1C
                 Key: CAMEL-25344
                 URL: https://issues.apache.org/jira/browse/CAMEL-25344
             Project: Camel
          Issue Type: Sub-task
          Components: camel-infinispan
    Affects Versions: 4.23.0
            Reporter: Aurélien Pupier


test is stable without -T1C

it was always either flaky or failed when launched with -T1C

{noformat}
org.infinispan.client.hotrod.exceptions.TransportException: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) 
failed with error(-111): Connection refused: localhost/[0:0:0:0:0:0:0:1]:11222  
      
        at 
java.util.concurrent.CompletableFuture.wrapInExecutionException(CompletableFuture.java:345)
  
        at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:440) 
        at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2117)      
        at org.infinispan.client.hotrod.impl.Util.await(Util.java:55)   
        at org.infinispan.client.hotrod.impl.Util.await(Util.java:50)   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.await(OperationDispatcher.java:998)
    
        at 
org.infinispan.client.hotrod.RemoteCacheManager.createRemoteCache(RemoteCacheManager.java:542)
       
        at 
org.infinispan.client.hotrod.RemoteCacheManager.getCache(RemoteCacheManager.java:273)
        
        at 
org.infinispan.client.hotrod.impl.RemoteSchemasAdminImpl.<init>(RemoteSchemasAdminImpl.java:44)
      
        at 
org.infinispan.client.hotrod.impl.RemoteCacheManagerAdminImpl.schemas(RemoteCacheManagerAdminImpl.java:175)
  
        at 
org.apache.camel.component.infinispan.remote.InfinispanRemoteQueryProducerIT.setupResources(InfinispanRemoteQueryProducerIT.java:111)
        
Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: 
finishConnect(..) failed with error(-111): Connection refused: 
localhost/[0:0:0:0:0:0:0:1]:11222 
Caused by: java.net.ConnectException: finishConnect(..) failed with 
error(-111): Connection refused     
        at io.netty.channel.unix.Errors.newConnectException0(Errors.java:166)   
        at io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:131)     
        at io.netty.channel.unix.Socket.finishConnect(Socket.java:361)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:772)
       
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:749)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)
{noformat}

{noformat}
java.util.concurrent.CompletionException: 
org.infinispan.api.exception.InfinispanException: 
java.util.concurrent.CompletionException: 
org.infinispan.client.hotrod.exceptions.TransportException:: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) 
failed with error(-111): Connection refused: localhost/[0:0:0:0:0:0:0:1]:11222 
        at 
java.util.concurrent.CompletableFuture.wrapInCompletionException(CompletableFuture.java:323)
 
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:359)
   
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:364)
 
        at 
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:1015)
 
        at 
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:995)
  
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:531) 
     
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2221)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.checkException(OperationDispatcher.java:831)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleResponse(OperationDispatcher.java:759)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleChannelFailure(OperationDispatcher.java:960)
     
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleConnectionFailure(OperationDispatcher.java:913)
  
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.handleError(OperationChannel.java:135)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.lambda$attemptConnect$0(OperationChannel.java:109)
        
        at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
     
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:597)
    
        at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:573)
  
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
     
        at 
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)   
        at 
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:643) 
        at 
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:132)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.fulfillConnectPromise(AbstractEpollChannel.java:736)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:755)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)       
Caused by: org.infinispan.api.exception.InfinispanException: 
java.util.concurrent.CompletionException: 
org.infinispan.client.hotrod.exceptions.TransportException:: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) 
failed with error(-111): Connection refused: localhost/[0:0:0:0:0:0:0:1]:11222  
      
        at 
org.infinispan.client.hotrod.impl.RemoteSchemasAdminImpl.lambda$callCreateOrUpdateSchema$0(RemoteSchemasAdminImpl.java:181)
  
        at 
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:1011)
 
        at 
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:995)
  
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:531) 
     
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2221)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.checkException(OperationDispatcher.java:831)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleResponse(OperationDispatcher.java:759)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleChannelFailure(OperationDispatcher.java:960)
     
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleConnectionFailure(OperationDispatcher.java:913)
  
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.handleError(OperationChannel.java:135)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.lambda$attemptConnect$0(OperationChannel.java:109)
        
        at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
     
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:597)
    
        at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:573)
  
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
     
        at 
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)   
        at 
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:643) 
        at 
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:132)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.fulfillConnectPromise(AbstractEpollChannel.java:736)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:755)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)       
Caused by: java.util.concurrent.CompletionException: 
org.infinispan.client.hotrod.exceptions.TransportException:: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) 
failed with error(-111): Connection refused: localhost/[0:0:0:0:0:0:0:1]:11222  
        at 
java.util.concurrent.CompletableFuture.wrapInCompletionException(CompletableFuture.java:323)
 
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:376)
   
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:391)
 
        at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:657)
  
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:531) 
     
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2221)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.checkException(OperationDispatcher.java:831)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleResponse(OperationDispatcher.java:759)
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleChannelFailure(OperationDispatcher.java:960)
     
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher.handleConnectionFailure(OperationDispatcher.java:913)
  
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.handleError(OperationChannel.java:135)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.lambda$attemptConnect$0(OperationChannel.java:109)
        
        at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
     
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:597)
    
        at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:573)
  
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
     
        at 
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)   
        at 
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:643) 
        at 
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:132)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.fulfillConnectPromise(AbstractEpollChannel.java:736)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:755)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)       
Caused by: org.infinispan.client.hotrod.exceptions.TransportException: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) 
failed with error(-111): Connection refused: localhost/[0:0:0:0:0:0:0:1]:11222  
   
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.handleError(OperationChannel.java:133)
    
        at 
org.infinispan.client.hotrod.impl.transport.netty.OperationChannel.lambda$attemptConnect$0(OperationChannel.java:109)
        
        at 
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
     
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:597)
    
        at 
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:573)
  
        at 
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
     
        at 
io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)   
        at 
io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:643) 
        at 
io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:132)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.fulfillConnectPromise(AbstractEpollChannel.java:736)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:755)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)       
Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: 
finishConnect(..) failed with error(-111): Connection refused: 
localhost/[0:0:0:0:0:0:0:1]:11222 
Caused by: java.net.ConnectException: finishConnect(..) failed with 
error(-111): Connection refused     
        at io.netty.channel.unix.Errors.newConnectException0(Errors.java:166)   
        at io.netty.channel.unix.Errors.handleConnectErrno(Errors.java:131)     
        at io.netty.channel.unix.Socket.finishConnect(Socket.java:361)  
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:772)
       
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:749)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:616)
 
        at 
io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.handle(AbstractEpollChannel.java:477)
        
        at 
io.netty.channel.epoll.EpollIoHandler$DefaultEpollIoRegistration.handle(EpollIoHandler.java:349)
     
        at 
io.netty.channel.epoll.EpollIoHandler.processReady(EpollIoHandler.java:548)  
        at io.netty.channel.epoll.EpollIoHandler.run(EpollIoHandler.java:491)   
        at 
io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
     
        at 
io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)  
     
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204)
        
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)    
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) 
     
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) 
     
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        
        at java.lang.Thread.run(Thread.java:1474)
{noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to