[not null][flinkStreamSQL支持not null 语法][17872]

Author: jiemotongxue

core/src/main/java/com/dtstack/flink/sql/table/AbsSourceParser.java

@@ -42,7 +42,7 @@ public abstract class AbsSourceParser extends AbsTableParser {
 
     private static Pattern virtualFieldKeyPattern = Pattern.compile("(?i)^(\\S+\\([^\\)]+\\))\\s+AS\\s+(\\w+)$");
     private static Pattern waterMarkKeyPattern = Pattern.compile("(?i)^\\s*WATERMARK\\s+FOR\\s+(\\S+)\\s+AS\\s+withOffset\\(\\s*(\\S+)\\s*,\\s*(\\d+)\\s*\\)$");
-    private static Pattern notNullKeyPattern = Pattern.compile("(?i)(\\w+)\\s+(\\w+)(\\s+NOT\\s+NULL)?$");
+    private static Pattern notNullKeyPattern = Pattern.compile("(?i)(\\w+)\\s+(\\w+)\\s+NOT\\s+NULL?$");
 
     static {
         keyPatternMap.put(VIRTUAL_KEY, virtualFieldKeyPattern);
@@ -74,9 +74,8 @@ static void dealNotNull(Matcher matcher, TableInfo tableInfo) {
         String fieldName = matcher.group(1);
         String fieldType = matcher.group(2);
         Class fieldClass= ClassUtil.stringConvertClass(fieldType);
-        boolean notNull = matcher.group(3) != null;
         TableInfo.FieldExtraInfo fieldExtraInfo = new TableInfo.FieldExtraInfo();
-        fieldExtraInfo.setNotNull(notNull);
+        fieldExtraInfo.setNotNull(true);
 
         tableInfo.addPhysicalMappings(fieldName, fieldName);
         tableInfo.addField(fieldName);