All Cassandra client thread stuck on session.execute

[Abhishek Kumar Maheshwari]

Hi Datastax support,

I am using Datastax Cassandra driver 3.1.2 with Kafka driver 1.0.0. Application is reading data from Kafka and dumping in Cassandra in batch mode (using prepared statement) . After some hour all Cassandra thread stuck on session.execute. below is thread dump. It was working fine with old Kafka driver version. I tried same thing with Cassandra driver version 3.3.0 but same issue. If I replace the prepared statement with simple insert statement everything working fine. Please let me know what I am doing wrong. 

Cassandra version: 3.0.9

Datastax Java driver version : 3.1.2/3.3.0

ConvOptJob-Attribution-10" - Thread t@94

   java.lang.Thread.State: WAITING

at sun.misc.Unsafe.park(Native Method)

- parking to wait for <5b510b7b> (a com.google.common.util.concurrent.AbstractFuture$Sync)

at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)

at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)

at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)

at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)

at com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:285)

at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116)

at com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly(Uninterruptibles.java:137)

at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:243)

at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68)

at com.toi.stream.service.ItemLineitemPerformanceService.getInsertQueryPerformaceItemLineitemData(ItemLineitemPerformanceService.java:148)

at com.toi.stream.service.ConversionOptimizationServiceImpl.processForOptimizationInCassandra(ConversionOptimizationServiceImpl.java:197)

[Jalali Sajad]

Hi

I have the same issue with 4.2.2 driver

after some time threads will be stuck

Can you help me about this issue?

"Camel (camel-1) thread #85 - seda://parallel" #242 daemon prio=5 os_prio=0 tid=0x00007fa7ae607800 nid=0x5ca4 waiting on condition [0x00007fa6739b7000]

   java.lang.Thread.State: WAITING (parking)

at sun.misc.Unsafe.park(Native Method)

- parking to wait for  <0x00000000faf21688> (a java.util.concurrent.CompletableFuture$Signaller)

at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)

at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1693)

at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)

at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1729)

at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)

at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:143)

at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:53)

at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:30)

at com.datastax.oss.driver.internal.core.session.DefaultSession.execute(DefaultSession.java:208)

at com.datastax.oss.driver.api.core.CqlSession.execute(CqlSession.java:51)

at com.datastax.oss.driver.internal.mapper.DaoBase.execute(DaoBase.java:178)

at com.datastax.oss.driver.internal.mapper.DaoBase.executeAndMapToEntityIterable(DaoBase.java:233)