(polaris) branch main updated: Fix error handler parameters in TaskExecutorImpl (#3358)

[dimas]

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

dimas pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/polaris.git


The following commit(s) were added to refs/heads/main by this push:
     new e99636c56 Fix error handler parameters in TaskExecutorImpl (#3358)
e99636c56 is described below

commit e99636c56acc1b99a0b7d8511f25d8fcba78de15
Author: Dmitri Bourlatchkov <dmitri.bourlatch...@gmail.com>
AuthorDate: Tue Jan 6 12:51:14 2026 -0500

    Fix error handler parameters in TaskExecutorImpl (#3358)
    
    Use correct exception variable inside 
`CompletableFuture.exceptionallyComposeAsync()`
---
 .../src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
 
b/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
index ca25b9357..a30fdac88 100644
--- 
a/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
+++ 
b/runtime/service/src/main/java/org/apache/polaris/service/task/TaskExecutorImpl.java
@@ -184,7 +184,7 @@ public class TaskExecutorImpl implements TaskExecutor {
         .exceptionallyComposeAsync(
             (t) -> {
               LOGGER.warn("Failed to handle task entity id {}", taskEntityId, 
t);
-              errorHandler.ifPresent(h -> h.accept(taskEntityId, false, e));
+              errorHandler.ifPresent(h -> h.accept(taskEntityId, false, t));
               return tryHandleTask(taskEntityId, callContext, eventMetadata, 
t, attempt + 1);
             },
             CompletableFuture.delayedExecutor(