Added debug log on waiting safe time.

gridgain · Dec 24, 2024 · a0b2e3e · a0b2e3e
1 parent e1a128e
commit a0b2e3e
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/.../src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java b/.../src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
@@ -40,6 +40,7 @@
 import org.apache.ignite.internal.logger.Loggers;
 import org.apache.ignite.internal.table.TableViewInternal;
 import org.apache.ignite.internal.test.WatchListenerInhibitor;
+import org.apache.ignite.internal.testframework.WithSystemProperty;
 import org.apache.ignite.internal.testframework.WorkDirectoryExtension;
 import org.apache.ignite.lang.IgniteException;
 import org.apache.ignite.sql.IgniteSql;
@@ -143,6 +144,7 @@ public void queryWaitAppropriateSchema() {
      * Test correctness of schemes recovery after node restart.
      */
     @Test
+    @WithSystemProperty(key = "IGNITE_PVD_DEBUG", value = "true")
     public void checkSchemasCorrectlyRestore() {
         Ignite ignite1 = cluster.node(1);
 

diff --git a/...ava/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java b/...ava/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -981,6 +981,19 @@ private CompletableFuture<List<BinaryRow>> processReadOnlyScanRetrieveBatchActio
         CompletableFuture<Void> safeReadFuture = isPrimaryInTimestamp(isPrimary, readTimestamp) ? nullCompletedFuture()
                 : safeTime.waitFor(readTimestamp);
 
+        if (IgniteSystemProperties.getBoolean("IGNITE_PVD_DEBUG", false)) {
+            long start = System.currentTimeMillis();
+
+            safeReadFuture.thenRun(() -> {
+                LOG.info(
+                        "Waiting safe time [isPrimary={}, readTimestamp={}, duration={}]",
+                        isPrimary,
+                        readTimestamp,
+                        System.currentTimeMillis() - start
+                );
+            });
+        }
+
         if (request.indexToUse() != null) {
             TableSchemaAwareIndexStorage indexStorage = secondaryIndexStorages.get().get(request.indexToUse());