[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