(ignite-3) branch main updated: [IGNITE-21418] More logging to debug this issue (#3888)

[sanpwc]

This is an automated email from the ASF dual-hosted git repository.

sanpwc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 4a23039089 [IGNITE-21418] More logging to debug this issue (#3888)
4a23039089 is described below

commit 4a23039089394a9356ac74dd3a578fbe3e2696c4
Author: Cyrill <cyrill.si...@gmail.com>
AuthorDate: Thu Jun 6 15:33:23 2024 +0300

    [IGNITE-21418] More logging to debug this issue (#3888)
---
 .../apache/ignite/internal/table/TxAbstractTest.java    | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git 
a/modules/table/src/testFixtures/java/org/apache/ignite/internal/table/TxAbstractTest.java
 
b/modules/table/src/testFixtures/java/org/apache/ignite/internal/table/TxAbstractTest.java
index 960d6f2e65..89be0add70 100644
--- 
a/modules/table/src/testFixtures/java/org/apache/ignite/internal/table/TxAbstractTest.java
+++ 
b/modules/table/src/testFixtures/java/org/apache/ignite/internal/table/TxAbstractTest.java
@@ -119,6 +119,7 @@ import org.apache.ignite.internal.type.NativeTypes;
 import org.apache.ignite.internal.util.CollectionUtils;
 import org.apache.ignite.internal.util.Lazy;
 import org.apache.ignite.internal.util.Pair;
+import org.apache.ignite.internal.util.PendingComparableValuesTracker;
 import org.apache.ignite.lang.IgniteException;
 import org.apache.ignite.network.ClusterNode;
 import org.apache.ignite.raft.jraft.RaftGroupService;
@@ -563,6 +564,14 @@ public abstract class TxAbstractTest extends 
IgniteAbstractTest {
                     IgniteTestUtils.getFieldValue(volatileTxState, 
VolatileTxStateMetaStorage.class, "txStateMap");
             logger().info("Volatile tx state data [node={}, data={}]", name, 
txStateMap);
         });
+
+        TxManager txManager = txTestCluster.clientTxManager();
+        VolatileTxStateMetaStorage volatileTxState =
+                IgniteTestUtils.getFieldValue(txManager, TxManagerImpl.class, 
"txStateVolatileStorage");
+
+        ConcurrentHashMap<UUID, TxStateMeta> txStateMap =
+                IgniteTestUtils.getFieldValue(volatileTxState, 
VolatileTxStateMetaStorage.class, "txStateMap");
+        logger().info("Volatile client tx state data [node={}, data={}]", 
"client", txStateMap);
     }
 
     private void printReplicaInfo(String name, ReplicationGroupId 
replicationGroupId, CompletableFuture<Replica> replicaCompletableFuture) {
@@ -583,7 +592,13 @@ public abstract class TxAbstractTest extends 
IgniteAbstractTest {
         TestMvPartitionStorage storage = 
IgniteTestUtils.getFieldValue(listener, PartitionReplicaListener.class, 
"mvDataStorage");
         Map<RowId, ?> map = IgniteTestUtils.getFieldValue(storage, 
TestMvPartitionStorage.class, "map");
 
-        logger().info("Partition data [node={}, groupId={}, data={}]", name, 
replicationGroupId, map);
+        PendingComparableValuesTracker<HybridTimestamp, Void> safeTime =
+                IgniteTestUtils.getFieldValue(listener, 
PartitionReplicaListener.class, "safeTime");
+
+        logger().info("Partition data "
+                        + "[node={}, groupId={}, data={}, lastAppliedIndex={}, 
lastAppliedTerm={}, leaseStartTime={}, safeTime = {}]",
+                name, replicationGroupId, map, storage.lastAppliedIndex(), 
storage.lastAppliedTerm(), storage.leaseStartTime(),
+                safeTime.current());
 
         Lazy<TableSchemaAwareIndexStorage> indexStorageLazy =
                 IgniteTestUtils.getFieldValue(listener, 
PartitionReplicaListener.class, "pkIndexStorage");