(flink) branch master updated: [hotfix][runtime] Minor polish the debug log for StreamTask.java

[panyuepeng]

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

RocMarshal 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 cc1926f142c [hotfix][runtime] Minor polish the debug log for 
StreamTask.java
cc1926f142c is described below

commit cc1926f142ce84e0253061e8e1c439ca8d7e6d36
Author: Yuepeng Pan <panyuep...@apache.org>
AuthorDate: Sat Oct 17 10:52:49 2026 +0800

    [hotfix][runtime] Minor polish the debug log for StreamTask.java
---
 .../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
 
b/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index 7bccacd79dd..b7f12973948 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -1329,9 +1329,9 @@ public abstract class StreamTask<OUT, OP extends 
StreamOperator<OUT>>
     @Override
     public final void cleanUp(Throwable throwable) throws Exception {
         LOG.debug(
-                String.format(
-                        "Cleanup StreamTask (operators closed: %b, cancelled: 
%b)",
-                        closedOperators, canceled),
+                "Cleanup StreamTask (operators closed: {}, cancelled: {})",
+                closedOperators,
+                canceled,
                 throwable);
 
         failing = !canceled && throwable != null;