[incubator-paimon] branch master updated: [hotfix] Add debug log to assigner and writer

[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 e22c4082b [hotfix] Add debug log to assigner and writer
e22c4082b is described below

commit e22c4082b9904ac6b9afd0688b69e208a9a398f4
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Mon Jul 10 18:03:19 2023 +0800

    [hotfix] Add debug log to assigner and writer
---
 .../src/main/java/org/apache/paimon/index/HashBucketAssigner.java | 8 +++++++-
 .../main/java/org/apache/paimon/io/KeyValueDataFileWriter.java    | 2 +-
 2 files changed, 8 insertions(+), 2 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 787af984e..aac1f0333 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
@@ -78,7 +78,13 @@ public class HashBucketAssigner {
             index = loadIndex(partition);
             this.partitionIndex.put(partition, index);
         }
-        return index.assign(hash, (bucket) -> computeAssignId(bucket) == 
assignId);
+
+        int assigned = index.assign(hash, (bucket) -> computeAssignId(bucket) 
== assignId);
+        if (LOG.isDebugEnabled()) {
+            LOG.debug(
+                    "Assign " + assigned + " to the partition " + partition + 
" key hash " + hash);
+        }
+        return assigned;
     }
 
     /** Prepare commit to clear outdated partition index. */
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java 
b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java
index 86ffc28fe..66a10f276 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java
@@ -112,7 +112,7 @@ public class KeyValueDataFileWriter
         updateMaxSeqNumber(kv);
 
         if (LOG.isDebugEnabled()) {
-            LOG.debug("Write key value " + kv.toString(keyType, valueType));
+            LOG.debug("Write to Path " + path + " key value " + 
kv.toString(keyType, valueType));
         }
     }