Merge branch 'feat_1.8_rowkey' into 1.8_test_3.10.x

dapeng · dapeng · commit 2e0c6c7cb207 · 2020-06-04T17:42:17.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/parser/CreateTableParser.java b/core/src/main/java/com/dtstack/flink/sql/parser/CreateTableParser.java
@@ -77,7 +77,7 @@ private Map parseProp(String propsStr){
         for(int i=0; i<strs.length; i++){
             List<String> ss = DtStringUtil.splitIgnoreQuota(strs[i], '=');
             String key = ss.get(0).trim();
-            String value = extractValue(ss.get(1));
+            String value = extractValue(ss.get(1).trim());
             propMap.put(key, value);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ private Map parseProp(String propsStr){`
`77`	`77`	`for(int i=0; i<strs.length; i++){`
`78`	`78`	`List<String> ss = DtStringUtil.splitIgnoreQuota(strs[i], '=');`
`79`	`79`	`String key = ss.get(0).trim();`
`80`		`- String value = extractValue(ss.get(1));`
	`80`	`+ String value = extractValue(ss.get(1).trim());`
`81`	`81`	`propMap.put(key, value);`
`82`	`82`	`}`
`83`	`83`