You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@paimon.apache.org by "dwangatt (via GitHub)" <gi...@apache.org> on 2026/06/18 01:40:26 UTC
[PR] Dwang/add compaction duration log [paimon]
dwangatt opened a new pull request, #8273:
URL: https://github.com/apache/paimon/pull/8273
### Purpose
- Add logs to trace the duration for compaction writer, so that in job log, we can analyse slow compaction task, bucket size distribution, slow partitions etc.
- Log real partition info instead of BinaryRow object address when Paimon detects inconsistent bucket setup during committing data to tables.
### Tests
No change to code logic, so existing UT/IT should cover the change from this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [core] Add compaction duration log [paimon]
Posted by "JingsongLi (via GitHub)" <gi...@apache.org>.
JingsongLi merged PR #8273:
URL: https://github.com/apache/paimon/pull/8273
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [core] Add compaction duration log [paimon]
Posted by "JingsongLi (via GitHub)" <gi...@apache.org>.
JingsongLi commented on code in PR #8273:
URL: https://github.com/apache/paimon/pull/8273#discussion_r3503572240
##########
paimon-core/src/main/java/org/apache/paimon/compact/CompactTask.java:
##########
@@ -37,22 +37,36 @@ public abstract class CompactTask implements Callable<CompactResult> {
@Nullable private final CompactionMetrics.Reporter metricsReporter;
+ @Nullable private String partitionString;
+ private int bucket = -1;
+
public CompactTask(@Nullable CompactionMetrics.Reporter metricsReporter) {
this.metricsReporter = metricsReporter;
}
+ /** Set partition and bucket info for logging purposes. */
+ public void setPartitionBucketInfo(@Nullable String partitionString, int bucket) {
Review Comment:
Just set a log info? `setLogInfo(String logInfo)`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@paimon.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org