From 18602e7fa6642580dcbc9667dcda2b8977a7f4d9 Mon Sep 17 00:00:00 2001
From: BJSTTLP416 <bjsttlp416@BJSTTLP416.local>
Date: Fri, 13 Feb 2026 19:33:26 +0800
Subject: [PATCH 1/2] [fix](schemachange) fix IndexChangeJob stuck on
 WAITING_TXN due to exception

---
 .../src/main/java/org/apache/doris/alter/IndexChangeJob.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java b/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
index 8d78530e0aa783..00ece03d1fe3fd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
@@ -344,6 +344,9 @@ protected void runWaitingTxnJob() throws AlterCancelException {
             if (!FeConstants.runningUnitTest) {
                 AgentTaskExecutor.submit(invertedIndexBatchTask);
             }
+        } catch(Exception e) {
+            LOG.error("run job {} failed due to {}", jobId, e);
+            throw new AlterCancelException(e.getMessage());
         } finally {
             olapTable.readUnlock();
         }

From 9e2bc2150a535fcac63da45e7b793847ac3734b2 Mon Sep 17 00:00:00 2001
From: Yulei-Yang <yulei.yang0699@gmail.com>
Date: Fri, 13 Feb 2026 19:43:00 +0800
Subject: [PATCH 2/2] fix code style

---
 .../src/main/java/org/apache/doris/alter/IndexChangeJob.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java b/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
index 00ece03d1fe3fd..2b5ca0ae1dd706 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/IndexChangeJob.java
@@ -344,7 +344,7 @@ protected void runWaitingTxnJob() throws AlterCancelException {
             if (!FeConstants.runningUnitTest) {
                 AgentTaskExecutor.submit(invertedIndexBatchTask);
             }
-        } catch(Exception e) {
+        } catch (Exception e) {
             LOG.error("run job {} failed due to {}", jobId, e);
             throw new AlterCancelException(e.getMessage());
         } finally {