error

Author: SiyaoIsHiding

integration-tests/src/test/java/com/datastax/oss/driver/core/cql/PreparedStatementCachingIT.java

@@ -123,11 +123,11 @@ private static RemovalListener<Object, Object> buildCacheRemoveCallback(
         @NonNull Optional<DefaultDriverContext> context) {
       return (evt) -> {
         try {
-          LOG.info("Cache removal callback triggered, cause: {}", evt.getCause());
+          LOG.error("Cache removal callback triggered, cause: {}", evt.getCause());
           CompletableFuture<PreparedStatement> future =
               (CompletableFuture<PreparedStatement>) evt.getValue();
           ByteBuffer queryId = Uninterruptibles.getUninterruptibly(future).getId();
-          LOG.info("Firing PreparedStatementRemovalEvent for queryId: {}", queryId);
+          LOG.error("Firing PreparedStatementRemovalEvent for queryId: {}", queryId);
           context.ifPresent(
               ctx -> ctx.getEventBus().fire(new PreparedStatementRemovalEvent(queryId)));
         } catch (Exception e) {
@@ -231,9 +231,9 @@ private void invalidationTestInner(
       ByteBuffer queryId2 = stmt2.getId();
       assertThat(getPreparedCacheSize(session)).isEqualTo(2);
 
-      LOG.info("Prepared statements in cache:");
-      LOG.info("  Statement 1: {} (queryId: {})", preparedStmtQueryType1, stmt1.getId());
-      LOG.info("  Statement 2: {} (queryId: {})", preparedStmtQueryType2, stmt2.getId());
+      LOG.error("Prepared statements in cache:");
+      LOG.error("  Statement 1: {} (queryId: {})", preparedStmtQueryType1, stmt1.getId());
+      LOG.error("  Statement 2: {} (queryId: {})", preparedStmtQueryType2, stmt2.getId());
 
       CountDownLatch preparedStmtCacheRemoveLatch = new CountDownLatch(1);
       CountDownLatch typeChangeEventLatch = new CountDownLatch(expectedChangedTypes.size());
@@ -251,7 +251,7 @@ private void invalidationTestInner(
               TypeChangeEvent.class,
               (e) -> {
                 // expect one event per type changed and for every parent type that nests it
-                LOG.info(
+                LOG.error(
                     "Received TypeChangeEvent for type: {} (changeType: {})",
                     e.oldType.getName(),
                     e.changeType);
@@ -267,7 +267,7 @@ private void invalidationTestInner(
           .register(
               PreparedStatementRemovalEvent.class,
               (e) -> {
-                LOG.info("Received PreparedStatementRemovalEvent for queryId: {}", e.queryId);
+                LOG.error("Received PreparedStatementRemovalEvent for queryId: {}", e.queryId);
                 if (!removedQueryIds.compareAndSet(Optional.empty(), Optional.of(e.queryId))) {
                   // store an error if we see multiple cache invalidation events
                   // any non-empty error will fail the test so it's OK to do this multiple times
@@ -280,8 +280,8 @@ private void invalidationTestInner(
               });
 
       // alter test_type_caching_2 to trigger cache invalidation and above events
-      LOG.info("Executing ALTER TYPE test_type_caching_2 add i blob");
-      LOG.info("Expected to invalidate statement 2 (queryId: {}) due to type change", queryId2);
+      LOG.error("Executing ALTER TYPE test_type_caching_2 add i blob");
+      LOG.error("Expected to invalidate statement 2 (queryId: {}) due to type change", queryId2);
       session.execute("ALTER TYPE test_type_caching_2 add i blob");
 
       // Give a small delay to allow the schema change to propagate before checking agreement