Skip to content

Commit 05329f8

Browse files
committed
[registerUDF 优化写法][flinkStreamSQL支持not null 语法][17872]
1 parent fb67128 commit 05329f8

File tree

1 file changed

+4
-1
lines changed
  • core/src/main/java/com/dtstack/flink/sql

1 file changed

+4
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/Main.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,10 +250,13 @@ private static void addEnvClassPath(StreamExecutionEnvironment env, Set<URL> cla
250250
private static void registerUDF(SqlTree sqlTree, List<URL> jarURList, URLClassLoader parentClassloader,
251251
StreamTableEnvironment tableEnv)
252252
throws ClassNotFoundException, NoSuchMethodException, IllegalAccessException, InvocationTargetException {
253+
List<CreateFuncParser.SqlParserResult> funcList = sqlTree.getFunctionList();
254+
if (funcList.isEmpty()) {
255+
return;
256+
}
253257
//load jar
254258
URLClassLoader classLoader = FlinkUtil.loadExtraJar(jarURList, parentClassloader);
255259
//register urf
256-
List<CreateFuncParser.SqlParserResult> funcList = sqlTree.getFunctionList();
257260
for (CreateFuncParser.SqlParserResult funcInfo : funcList) {
258261
FlinkUtil.registerUDF(funcInfo.getType(), funcInfo.getClassName(), funcInfo.getName(),
259262
tableEnv, classLoader);

0 commit comments

Comments
 (0)