Skip to content

Commit 87696d3

Browse files
committed
print detail log info
1 parent c098bd9 commit 87696d3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/java/com/dtstack/flink/sql/util/FlinkUtil.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,7 @@ public static void registerScalaUDF(String classPath, String funcName, TableEnvi
180180
logger.info("register scala function:{} success.", funcName);
181181
}catch (Exception e){
182182
logger.error("", e);
183-
throw new RuntimeException("register UDF exception:" + e.getMessage());
183+
throw new RuntimeException("register UDF exception:", e);
184184
}
185185
}
186186

@@ -208,7 +208,7 @@ public static void registerTableUDF(String classPath, String funcName, TableEnvi
208208
logger.info("register table function:{} success.", funcName);
209209
}catch (Exception e){
210210
logger.error("", e);
211-
throw new RuntimeException("register Table UDF exception:" + e.getMessage());
211+
throw new RuntimeException("register Table UDF exception:", e);
212212
}
213213
}
214214

0 commit comments

Comments
 (0)