(hudi) branch master updated: fix(flink): include exception stacktrace in error logs (#18091)

[yihua]

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

yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new bd52f592570b fix(flink): include exception stacktrace in error logs 
(#18091)
bd52f592570b is described below

commit bd52f592570bd4599fbbc40c1d9804f6bde4a235
Author: Prashant Wason <pwa...@uber.com>
AuthorDate: Wed Feb 11 17:19:00 2026 -0800

    fix(flink): include exception stacktrace in error logs (#18091)
---
 .../java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
index d12dccd1195d..179b83e1664b 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
@@ -644,14 +644,14 @@ public class StreamWriteOperatorCoordinator
       log.error("The first 10 files with write errors:");
       
dataWriteResults.stream().filter(WriteStatus::hasErrors).limit(10).forEach(ws 
-> {
         if (ws.getGlobalError() != null) {
-          log.error("Global error for partition path {} and fileID {}: {}",
+          log.error("Global error for partition path {} and fileID {}: ",
               ws.getPartitionPath(), ws.getFileId(), ws.getGlobalError());
         }
         if (!ws.getErrors().isEmpty()) {
           log.error("The first 100 records-level errors for partition path {} 
and fileID {}:",
               ws.getPartitionPath(), ws.getFileId());
           ws.getErrors().entrySet().stream().limit(100).forEach(entry ->
-              log.error("Error for key: {} and Exception: {}", entry.getKey(), 
entry.getValue().getMessage()));
+              log.error("Error for key {}: ", entry.getKey(), 
entry.getValue()));
         }
       });
     }