[incubator-paimon] branch master updated: [core] More debug message for latestCommittedIdentifier

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new b4c934377 [core] More debug message for latestCommittedIdentifier
b4c934377 is described below

commit b4c9343770225b34785865aec816fdbba6dbfaf8
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Thu Jul 6 12:05:47 2023 +0800

    [core] More debug message for latestCommittedIdentifier
---
 .../src/main/java/org/apache/paimon/index/HashBucketAssigner.java   | 6 ++++--
 .../java/org/apache/paimon/operation/AbstractFileStoreWrite.java    | 6 ++++--
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java 
b/paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java
index ecf013150..934b2df97 100644
--- a/paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java
+++ b/paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java
@@ -118,10 +118,12 @@ public class HashBucketAssigner {
                         LOG.debug(
                                 "Removing index for partition {}. "
                                         + "Index's last accessed identifier is 
{}, "
-                                        + "while latest committed identifier 
is {}",
+                                        + "while latest committed identifier 
is {}, "
+                                        + "current commit identifier is {}.",
                                 partition,
                                 index.lastAccessedCommitIdentifier,
-                                latestCommittedIdentifier);
+                                latestCommittedIdentifier,
+                                commitIdentifier);
                     }
                     iterator.remove();
                 }
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
 
b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
index 23443f3ad..33a72eafc 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
@@ -199,11 +199,13 @@ public abstract class AbstractFileStoreWrite<T>
                             LOG.debug(
                                     "Closing writer for partition {}, bucket 
{}. "
                                             + "Writer's last modified 
identifier is {}, "
-                                            + "while latest committed 
identifier is {}",
+                                            + "while latest committed 
identifier is {}, "
+                                            + "current commit identifier is 
{}.",
                                     partition,
                                     bucket,
                                     
writerContainer.lastModifiedCommitIdentifier,
-                                    latestCommittedIdentifier);
+                                    latestCommittedIdentifier,
+                                    commitIdentifier);
                         }
                         writerContainer.writer.close();
                         bucketIter.remove();