Throw exception on unreachable branches

Signed-off-by: yuxiqian <[email protected]>
apache · Oct 12, 2024 · ed28d6c · ed28d6c
1 parent f1bdd14
commit ed28d6c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...c-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java b/...c-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java
@@ -686,7 +686,9 @@ private static TimestampData castToTimestamp(Object object, String timezone) {
                     LocalDateTime.ofInstant(
                             ((ZonedTimestampData) object).toInstant(), ZoneId.of(timezone)));
         } else {
-            return TimestampData.fromLocalDateTime(LocalDateTime.parse(String.valueOf(object)));
+            throw new IllegalArgumentException(
+                    String.format(
+                            "Unable to implicitly coerce object `%s` as a TIMESTAMP.", object));
         }
     }
 }