[hotfix][hive] adapt HiveFunctionDefinitionFactory.createFunctionDefi…

…nition to latest APPI
spotify · Dec 8, 2019 · 1858ce2 · 1858ce2
1 parent 5bc914e
commit 1858ce2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/org/apache/flink/table/catalog/hive/factories/HiveFunctionDefinitionFactory.java b/...ain/java/org/apache/flink/table/catalog/hive/factories/HiveFunctionDefinitionFactory.java
@@ -63,7 +63,7 @@ public HiveFunctionDefinitionFactory(HiveShim hiveShim) {
  @Override
  public FunctionDefinition createFunctionDefinition(String name, CatalogFunction catalogFunction) {
  if (catalogFunction.isGeneric()) {
- return FunctionDefinitionUtil.createFunctionDefinition(name, catalogFunction);
+ return FunctionDefinitionUtil.createFunctionDefinition(name, catalogFunction.getClassName());
  }
 
  return createFunctionDefinitionFromHiveFunction(name, catalogFunction.getClassName());