You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2025/09/19 14:32:03 UTC
(flink) branch master updated: [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 07fabaa36bf [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error
07fabaa36bf is described below
commit 07fabaa36bf5af4526d05657900722baea928491
Author: Sergey Nuyanzin <sn...@gmail.com>
AuthorDate: Fri Sep 19 16:31:56 2025 +0200
[FLINK-38378][table] Use ValidationException in CatalogManager in case of user error
---
.../main/java/org/apache/flink/table/catalog/CatalogManager.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
index c1ee34749af..24ebe07e9ea 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
@@ -708,7 +708,7 @@ public final class CatalogManager implements CatalogRegistry, AutoCloseable {
return getTable(objectIdentifier)
.orElseThrow(
() ->
- new TableException(
+ new ValidationException(
String.format(
"Cannot find table '%s' in any of the catalogs %s, nor as a temporary table.",
objectIdentifier, listCatalogs())));
@@ -748,7 +748,7 @@ public final class CatalogManager implements CatalogRegistry, AutoCloseable {
if (timestamp != null) {
table = currentCatalog.getTable(objectPath, timestamp);
if (table.getTableKind() == TableKind.VIEW) {
- throw new TableException(
+ throw new ValidationException(
String.format(
"%s is a view, but time travel is not supported for view.",
objectIdentifier.asSummaryString()));
@@ -1448,7 +1448,7 @@ public final class CatalogManager implements CatalogRegistry, AutoCloseable {
return getModel(objectIdentifier)
.orElseThrow(
() ->
- new TableException(
+ new ValidationException(
String.format(
"Cannot find model '%s' in any of the catalogs %s.",
objectIdentifier, listCatalogs())));