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/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(
@@ -528,6 +528,6 @@ public void removeNode(InetSocketAddress broadcastRpcAddress) {
 
   // Wait for all the tasks on the pool's admin executor to complete.
   private void waitForPendingAdminTasks(Callable<Boolean> condition) {
-    await().atMost(500, TimeUnit.MILLISECONDS).until(condition);
+    await().atMost(5, TimeUnit.SECONDS).until(condition);
   }
 }

examples/pom.xml

@@ -151,6 +151,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

metrics/micrometer/src/main/java/com/datastax/oss/driver/internal/metrics/micrometer/MicrometerMetricUpdater.java

@@ -55,22 +55,22 @@ protected MicrometerMetricUpdater(
   @Override
   public void incrementCounter(MetricT metric, @Nullable String profileName, long amount) {
     if (isEnabled(metric, profileName)) {
-      getOrCreateCounterFor(metric).increment(amount);
+      getOrCreateCounterFor(metric).increment((double) amount);
     }
   }
 
   @Override
   public void updateHistogram(MetricT metric, @Nullable String profileName, long value) {
     if (isEnabled(metric, profileName)) {
-      getOrCreateDistributionSummaryFor(metric).record(value);
+      getOrCreateDistributionSummaryFor(metric).record((double) value);
     }
   }
 
   @Override
   public void markMeter(MetricT metric, @Nullable String profileName, long amount) {
     if (isEnabled(metric, profileName)) {
       // There is no meter type in Micrometer, so use a counter
-      getOrCreateCounterFor(metric).increment(amount);
+      getOrCreateCounterFor(metric).increment((double) amount);
     }
   }