Add recursion guard to prevent infinite splitting in batch processing

main/backplane-cassandra2/src/main/java/org/elasticsoftware/elasticactors/cassandra2/state/PersistentActorUpdateEventProcessor.java

@@ -178,6 +178,11 @@ private void executeBatchV1(List<PersistentActorUpdateEvent> events) {
         try {
             executeWithRetry(cassandraSession, batchStatement.bind(arguments.toArray()), logger);
         } catch(BatchTooLargeException e) {
+            // Guard against infinite recursion: if we can't split further, fail with a clear error
+            if(events.size() <= 1) {
+                logger.error("Single event of byteSize {} is too large to execute", e.getBatchSize());
+                throw new IllegalStateException("Single event is too large to process", e);
+            }
             int half = events.size() / 2;
             // batch is too large, so we need to split it up
             logger.warn(
@@ -215,6 +220,11 @@ private void executeBatchV1Optimized(List<PersistentActorUpdateEvent> events) {
             try {
                 executeWithRetry(cassandraSession, batchStatement.bind(arguments.toArray()), logger);
             } catch(BatchTooLargeException e) {
+                // Guard against infinite recursion: if we can't split further, fail with a clear error
+                if(events.size() <= 1) {
+                    logger.error("Single event of byteSize {} is too large to execute", e.getBatchSize());
+                    throw new IllegalStateException("Single event is too large to process", e);
+                }
                 int half = events.size() / 2;
                 // batch is too large, so we need to split it up
                 logger.warn(
@@ -244,6 +254,11 @@ private void executeBatchV2AndUp(List<PersistentActorUpdateEvent> events) {
         try {
             executeWithRetry(cassandraSession, batchStatement, logger);
         } catch(BatchTooLargeException e) {
+            // Guard against infinite recursion: if we can't split further, fail with a clear error
+            if(events.size() <= 1) {
+                logger.error("Single event of byteSize {} is too large to execute", e.getBatchSize());
+                throw new IllegalStateException("Single event is too large to process", e);
+            }
             int half = events.size() / 2;
             // batch is too large, so we need to split it up
             logger.warn(

main/backplane-cassandra4/src/main/java/org/elasticsoftware/elasticactors/cassandra4/state/PersistentActorUpdateEventProcessor.java

@@ -116,6 +116,11 @@ private void executeBatchV3AndUp(List<PersistentActorUpdateEvent> events) {
         try {
             executeWithRetry(cassandraSession, batchStatement, logger);
         } catch (BatchTooLargeException e) {
+            // Guard against infinite recursion: if we can't split further, fail with a clear error
+            if(events.size() <= 1) {
+                logger.error("Single event of byteSize {} is too large to execute", e.getBatchSize());
+                throw new IllegalStateException("Single event is too large to process", e);
+            }
             int half = events.size() / 2;
             // batch is too large, so we need to split it up
             logger.warn(

main/backplane-cassandra4/src/test/java/org/elasticsoftware/elasticactors/cassandra4/state/PersistentActorUpdateEventProcessorTest.java

@@ -201,4 +201,3 @@ public void testProcessBatchTooLargeWithNineEvents() {
     }
 
 }
-