This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 03e57af1f65 [FLINK-40523][network] Compute tracePersist debug string
only when trace logging is enabled
03e57af1f65 is described below
commit 03e57af1f65fa0718a4e592abced9e8d7dc37a72
Author: Rui Fan <[email protected]>
AuthorDate: Mon Aug 31 18:43:55 2026 +0200
[FLINK-40523][network] Compute tracePersist debug string only when trace
logging is enabled
---
.../apache/flink/runtime/io/network/logger/NetworkActionsLogger.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
index 137334ae14f..231fbcbb2a0 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
@@ -98,7 +98,9 @@ public class NetworkActionsLogger {
public static void tracePersist(
String action, Buffer buffer, Object channelInfo, long
checkpointId) {
- tracePersist(action, buffer.toDebugString(INCLUDE_HASH), channelInfo,
checkpointId);
+ if (LOG.isTraceEnabled()) {
+ tracePersist(action, buffer.toDebugString(INCLUDE_HASH),
channelInfo, checkpointId);
+ }
}
public static void tracePersist(
