[flink-tidb-connector] fix the exception caused by calling the `getFu…

…nction` method of TIDBCatalog (#63)
tidb-incubator · Apr 2, 2021 · 9c06f70 · 9c06f70
1 parent 30033ad
commit 9c06f70
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink/flink-base/src/main/java/io/tidb/bigdata/flink/tidb/TiDBBaseCatalog.java b/flink/flink-base/src/main/java/io/tidb/bigdata/flink/tidb/TiDBBaseCatalog.java
@@ -277,7 +277,7 @@ public List<String> listFunctions(String dbName)
   @Override
   public CatalogFunction getFunction(ObjectPath functionPath)
       throws FunctionNotExistException, CatalogException {
-    throw new UnsupportedOperationException();
+    throw new FunctionNotExistException(getName(), functionPath);
   }
 
   @Override