fix based on CR

apache · Aug 21, 2024 · 93ae49c · 93ae49c
1 parent 521687e
commit 93ae49c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...c/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java b/...c/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;
         }
     }