We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b16a9fd commit 557f350Copy full SHA for 557f350
1 file changed
core/src/main/java/com/dtstack/flink/sql/parser/SqlParser.java
@@ -64,10 +64,6 @@ public static SqlTree parseSql(String sql) throws Exception {
64
throw new RuntimeException("sql is not null");
65
}
66
67
- if(LOCAL_SQL_PLUGIN_ROOT == null){
68
- throw new RuntimeException("need to set local sql plugin root");
69
- }
70
-
71
sql = DtStringUtil.dealSqlComment(sql)
72
.replaceAll("\r\n", " ")
73
.replaceAll("\n", " ")
0 commit comments