test: fix Java 11 test compatibility and CI failures

Enable required annotation processors, silence Java 11 compiler warnings, and improve CCM cleanup logging so integration failures are easier to diagnose.

Update tests for newer Mockito behavior by avoiding shared MockitoJUnitRunner usage in parallel integration tests and by verifying cache interactions explicitly where the mock behavior changed.

Fix CI failures exposed by the updated validation matrix: provide Micrometer histogram bounds in the no-SLA test, register config-change listeners before manual reloads, avoid assuming a transient one-connection node state before reconnection wins the race, and validate prepared-statement invalidation through observable cache behavior instead of a test-only removal-listener latch.

Author: dkropachev

core/src/main/java/com/datastax/oss/driver/api/core/paging/OffsetPager.java

@@ -46,7 +46,7 @@
  * a reasonable trade-off if the cardinality stays low. This class provides a way to emulate this
  * behavior on the client side.
  *
- * <h3>Performance considerations</h3>
+ * <h2>Performance considerations</h2>
  *
  * For each page that you want to retrieve:
  *
@@ -71,7 +71,7 @@
  * OffsetPager.Page&lt;Row&gt; page5 = pager.getPage(rs, 5);
  * </pre>
  *
- * <h3>Establishing application-level guardrails</h3>
+ * <h2>Establishing application-level guardrails</h2>
  *
  * Linear performance should be fine for the values typically encountered in real-world
  * applications: for example, if the page size is 25 and users never go past page 10, the worst case
@@ -81,7 +81,7 @@
  * maximum, so that an attacker can't inject a large value that could potentially fetch millions of
  * rows.
  *
- * <h3>Relation with protocol-level paging</h3>
+ * <h2>Relation with protocol-level paging</h2>
  *
  * Protocol-level paging refers to the ability to split large response into multiple network chunks:
  * see {@link Statement#setPageSize(int)} and {@code basic.request.page-size} in the configuration.

core/src/test/java/com/datastax/oss/driver/internal/core/metadata/MetadataManagerTest.java

@@ -389,9 +389,9 @@ public void refreshSchema_should_drain_queued_refresh_after_newInstance_failure(
     CompletionStage<MetadataManager.RefreshSchemaResult> result2 =
         metadataManager.refreshSchema("bar", true, true);
 
-    // Now complete the agreement check - first refresh will fail at newInstance(),
-    // and onSchemaRefreshComplete should drain the queued second refresh
-    agreementFuture.complete(true);
+    // Now complete the agreement check on the admin event loop - first refresh will fail at
+    // newInstance(), and onSchemaRefreshComplete should drain the queued second refresh.
+    adminEventLoopGroup.next().execute(() -> agreementFuture.complete(true));
 
     // Then both requests should complete (not hang forever)
     waitForPendingAdminTasks(

examples/pom.xml

@@ -154,6 +154,11 @@
           <source>11</source>
           <target>11</target>
           <annotationProcessorPaths>
+            <path>
+              <groupId>com.google.errorprone</groupId>
+              <artifactId>error_prone_core</artifactId>
+              <version>2.31.0</version>
+            </path>
             <path>
               <groupId>com.scylladb</groupId>
               <artifactId>java-driver-mapper-processor</artifactId>

examples/src/main/java/com/datastax/oss/driver/examples/paging/ForwardPagingRestUi.java

@@ -119,7 +119,7 @@ private static void populateSchema(CqlSession session) {
         int videoid = i * 100 + j;
         session.execute(
             prepare.bind(
-                i, "user " + i, Instant.ofEpochMilli(j * 100000), videoid, "video " + videoid));
+                i, "user " + i, Instant.ofEpochMilli(j * 100000L), videoid, "video " + videoid));
       }
     }
   }

examples/src/main/java/com/datastax/oss/driver/examples/paging/RandomPagingRestUi.java

@@ -129,7 +129,7 @@ private static void populateSchema(CqlSession session) {
         int videoid = i * 100 + j;
         session.execute(
             prepare.bind(
-                i, "user " + i, Instant.ofEpochMilli(j * 100000), videoid, "video " + videoid));
+                i, "user " + i, Instant.ofEpochMilli(j * 100000L), videoid, "video " + videoid));
       }
     }
   }

integration-tests/pom.xml

@@ -231,6 +231,42 @@
   </dependencies>
   <build>
     <plugins>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <configuration>
+          <compilerArgs combine.children="append">
+            <compilerArg>-processor</compilerArg>
+            <compilerArg>com.datastax.oss.driver.internal.mapper.processor.MapperProcessor,com.datastax.oss.driver.internal.gremlin.PatchedGremlinDslProcessor</compilerArg>
+          </compilerArgs>
+          <annotationProcessorPaths>
+            <path>
+              <groupId>com.google.errorprone</groupId>
+              <artifactId>error_prone_core</artifactId>
+              <version>2.31.0</version>
+            </path>
+            <path>
+              <groupId>com.scylladb</groupId>
+              <artifactId>java-driver-test-infra</artifactId>
+              <version>${project.version}</version>
+            </path>
+            <path>
+              <groupId>com.scylladb</groupId>
+              <artifactId>java-driver-mapper-processor</artifactId>
+              <version>${project.version}</version>
+            </path>
+            <path>
+              <groupId>com.scylladb</groupId>
+              <artifactId>java-driver-mapper-runtime</artifactId>
+              <version>${project.version}</version>
+            </path>
+            <path>
+              <groupId>org.apache.tinkerpop</groupId>
+              <artifactId>gremlin-core</artifactId>
+              <version>${tinkerpop.version}</version>
+            </path>
+          </annotationProcessorPaths>
+        </configuration>
+      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-failsafe-plugin</artifactId>

integration-tests/src/test/java/com/datastax/oss/driver/core/config/DriverExecutionProfileReloadIT.java

@@ -125,8 +125,8 @@ public void should_reload_configuration_when_event_fired() {
 
       // Bump up request timeout to 10 seconds and trigger a manual reload.
       configSource.set("basic.request.timeout = 10s");
-      session.getContext().getConfigLoader().reload();
-      waitForConfigChange(session, 500, TimeUnit.MILLISECONDS);
+      waitForConfigChange(
+          session, () -> session.getContext().getConfigLoader().reload(), 3, TimeUnit.SECONDS);
 
       // Execute again, should not timeout.
       session.execute(query);
@@ -217,11 +217,17 @@ public void should_reload_profile_config_when_reloading_config() {
   }
 
   private void waitForConfigChange(CqlSession session, long timeout, TimeUnit unit) {
+    waitForConfigChange(session, () -> {}, timeout, unit);
+  }
+
+  private void waitForConfigChange(
+      CqlSession session, Runnable trigger, long timeout, TimeUnit unit) {
     CountDownLatch latch = new CountDownLatch(1);
     ((InternalDriverContext) session.getContext())
         .getEventBus()
         .register(ConfigChangeEvent.class, (e) -> latch.countDown());
     try {
+      trigger.run();
       boolean success = latch.await(timeout, unit);
       assertThat(success).isTrue();
     } catch (InterruptedException e) {

integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/NodeStateIT.java

@@ -81,12 +81,9 @@
 import org.junit.experimental.categories.Category;
 import org.junit.rules.RuleChain;
 import org.junit.rules.TestRule;
-import org.junit.runner.RunWith;
 import org.mockito.InOrder;
-import org.mockito.junit.MockitoJUnitRunner;
 
 @Category(ParallelizableTests.class)
-@RunWith(MockitoJUnitRunner.class)
 public class NodeStateIT {
 
   private SimulacronRule simulacron = new SimulacronRule(ClusterSpec.builder().withNodes(2));
@@ -213,10 +210,13 @@ public void should_keep_regular_node_up_when_still_one_connection() {
     simulacron.cluster().closeConnection(report.getConnections().get(0), CloseType.DISCONNECT);
 
     await()
-        .alias("Reconnection started")
+        .alias("Regular node stayed up after one connection closed")
         .pollInterval(500, TimeUnit.MILLISECONDS)
         .untilAsserted(
-            () -> assertThat(metadataRegularNode).isUp().hasOpenConnections(1).isReconnecting());
+            () -> {
+              assertThat(metadataRegularNode).isUp();
+              assertThat(metadataRegularNode.getOpenConnections()).isBetween(1, 2);
+            });
     inOrder.verify(nodeStateListener, never()).onDown(metadataRegularNode);
   }
 

integration-tests/src/test/java/com/datastax/oss/driver/core/session/ListenersIT.java

@@ -42,19 +42,19 @@
 import java.util.Collections;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import org.junit.After;
+import org.junit.Before;
 import org.junit.ClassRule;
 import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
-import org.junit.runner.RunWith;
 import org.mockito.ArgumentCaptor;
 import org.mockito.Captor;
 import org.mockito.InOrder;
 import org.mockito.Mock;
-import org.mockito.junit.MockitoJUnitRunner;
+import org.mockito.MockitoAnnotations;
 
 @Category(ParallelizableTests.class)
-@RunWith(MockitoJUnitRunner.class)
 public class ListenersIT {
 
   @ClassRule
@@ -71,6 +71,18 @@ public class ListenersIT {
   @Captor private ArgumentCaptor<Node> nodeCaptor1;
   @Captor private ArgumentCaptor<Node> nodeCaptor2;
 
+  private AutoCloseable mocks;
+
+  @Before
+  public void setup() {
+    mocks = MockitoAnnotations.openMocks(this);
+  }
+
+  @After
+  public void teardown() throws Exception {
+    mocks.close();
+  }
+
   @Test
   @Ignore(
       "@IntegrationTestDisabledFlaky") // sleep after build() fixes the flakiness, session readiness

integration-tests/src/test/java/com/datastax/oss/driver/core/tracker/RequestLoggerIT.java

@@ -59,16 +59,14 @@
 import org.junit.experimental.categories.Category;
 import org.junit.rules.RuleChain;
 import org.junit.rules.TestRule;
-import org.junit.runner.RunWith;
 import org.mockito.ArgumentCaptor;
 import org.mockito.Captor;
 import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
 import org.mockito.internal.verification.VerificationModeFactory;
-import org.mockito.junit.MockitoJUnitRunner;
 import org.mockito.verification.Timeout;
 import org.slf4j.LoggerFactory;
 
-@RunWith(MockitoJUnitRunner.class)
 @Category(ParallelizableTests.class)
 public class RequestLoggerIT {
   private static final Pattern LOG_PREFIX_PER_REQUEST = Pattern.compile("\\[s\\d*\\|\\d*]");
@@ -192,19 +190,26 @@ public class RequestLoggerIT {
   @Mock private Appender<ILoggingEvent> appender;
   private Logger logger;
   private Level oldLevel;
+  private AutoCloseable mocks;
 
   @Before
   public void setup() {
+    mocks = MockitoAnnotations.openMocks(this);
     logger = (Logger) LoggerFactory.getLogger(RequestLogger.class);
     oldLevel = logger.getLevel();
     logger.setLevel(Level.INFO);
     logger.addAppender(appender);
   }
 
   @After
-  public void teardown() {
-    logger.detachAppender(appender);
-    logger.setLevel(oldLevel);
+  public void teardown() throws Exception {
+    if (logger != null) {
+      logger.detachAppender(appender);
+      logger.setLevel(oldLevel);
+    }
+    if (mocks != null) {
+      mocks.close();
+    }
   }
 
   @Test