File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
core/src/main/java/com/dtstack/flink/sql Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ public abstract class AbstractTableParser {
4444 private static final String CHAR_TYPE_NO_LENGTH = "CHAR" ;
4545
4646 private static Pattern primaryKeyPattern = Pattern .compile ("(?i)PRIMARY\\ s+KEY\\ s*\\ ((.*)\\ )" );
47- private static Pattern nestJsonFieldKeyPattern = Pattern .compile ("(?i)((@*\\ S+\\ .)*\\ S+)\\ s+(.+)\\ s+AS\\ s+(\\ w+)(\\ s+NOT\\ s+NULL)?$" );
47+ private static Pattern nestJsonFieldKeyPattern = Pattern .compile ("(?i)((@*\\ S+\\ .)*\\ S+)\\ s+(.+? )\\ s+AS\\ s+(\\ w+)(\\ s+NOT\\ s+NULL)?$" );
4848 private static Pattern physicalFieldFunPattern = Pattern .compile ("\\ w+\\ ((\\ w+)\\ )$" );
4949 private static Pattern charTypePattern = Pattern .compile ("(?i)CHAR\\ ((\\ d*)\\ )$" );
5050
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ public class ClassUtil {
3737 public static Class <?> stringConvertClass (String str ) {
3838
3939 // 这部分主要是告诉Class转TypeInfomation的方法,字段是Array类型
40- String lowerStr = str .toLowerCase ();
40+ String lowerStr = str .toLowerCase (). trim () ;
4141 if (lowerStr .startsWith ("array" )) {
4242 return Array .newInstance (Integer .class , 0 ).getClass ();
4343 }
You can’t perform that action at this time.
0 commit comments