From 9533db1cfe9ab77a4abb533df5a6ed665f59ead7 Mon Sep 17 00:00:00 2001 From: Rui Fan <1996fanrui@gmail.com> Date: Mon, 31 Aug 2026 18:43:55 +0200 Subject: [PATCH] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled --- .../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 137334ae14fc35..231fbcbb2a07ad 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 static void traceRecover( 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(