From 93ae49cd79a75719454a2977cd2dc60d3b87f02a Mon Sep 17 00:00:00 2001
From: Hongshun Wang <loserwang1024@gmail.com>
Date: Wed, 21 Aug 2024 16:38:43 +0800
Subject: [PATCH] fix based on CR

---
 .../runtime/operators/schema/coordinator/SchemaRegistry.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
index 21abd05c81..9087ae4b36 100644
--- a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
+++ b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
@@ -277,8 +277,9 @@ public void resetToCheckpoint(long checkpointId, @Nullable byte[] checkpointData
                     throw new IOException(
                             "Unrecognized serialization version " + schemaManagerSerializerVersion);
             }
-        } catch (Throwable throwable) {
-            context.failJob(throwable);
+        } catch (Throwable t) {
+            context.failJob(t);
+            throw t;
         }
     }