Skip to content

Commit

Permalink
KAFKA-16685: Add parent exception to RLMTask warning logs (apache#15880)
Browse files Browse the repository at this point in the history
KAFKA-16685: Add parent exception to RLMTask warning logs

Reviewers: Josep Prat <[email protected]>
  • Loading branch information
jeqo committed May 10, 2024
1 parent a6b8edd commit c1cf8eb
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions core/src/main/java/kafka/log/remote/RemoteLogManager.java
Original file line number Diff line number Diff line change
Expand Up @@ -802,14 +802,13 @@ public void run() {
}
} catch (InterruptedException ex) {
if (!isCancelled()) {
logger.warn("Current thread for topic-partition-id {} is interrupted. Reason: {}", topicIdPartition, ex.getMessage());
logger.warn("Current thread for topic-partition-id {} is interrupted", topicIdPartition, ex);
}
} catch (RetriableException ex) {
logger.debug("Encountered a retryable error while executing current task for topic-partition {}", topicIdPartition, ex);
} catch (Exception ex) {
if (!isCancelled()) {
logger.warn("Current task for topic-partition {} received error but it will be scheduled. " +
"Reason: {}", topicIdPartition, ex.getMessage());
logger.warn("Current task for topic-partition {} received error but it will be scheduled", topicIdPartition, ex);
}
}
}
Expand Down

0 comments on commit c1cf8eb

Please sign in to comment.