davidradl commented on code in PR #26861:
URL: https://github.com/apache/flink/pull/26861#discussion_r2273553226
##########
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##########
@@ -1072,7 +1072,8 @@ public final void cleanUp(Throwable throwable) throws
Exception {
LOG.debug(
"Cleanup StreamTask (operators closed: {}, cancelled: {})",
closedOperators,
- canceled);
+ canceled,
+ throwable);
Review Comment:
Does the throwable information come out in the dbeug?
I see the Logger.debug interface is
```
public void debug(String format, Object... arguments);
/**
* Log an exception (throwable) at the DEBUG level with an
* accompanying message.
*
* @param msg the message accompanying the exception
* @param t the exception (throwable) to log
*/
public void debug(String msg, Throwable t);
```
It looks like we should pass a resolved string and the throwable or have the
Throwable as an insert in the message.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
