(flink) branch master updated: [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error

[snuyanzin]

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 <snuyan...@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())));