Skip to content

Commit 8ba8706

Browse files
committed
[fix][hbase] rowKey not available.
1 parent ae2aaf9 commit 8ba8706

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/parser/CreateTableParser.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020

2121
import com.dtstack.flink.sql.util.DtStringUtil;
2222
import com.google.common.collect.Maps;
23+
import org.apache.commons.lang3.StringUtils;
2324

2425
import java.util.List;
2526
import java.util.Map;
@@ -72,13 +73,18 @@ private Map<String, Object> parseProp(String propsStr){
7273
for (String str : strings) {
7374
List<String> ss = DtStringUtil.splitIgnoreQuota(str, '=');
7475
String key = ss.get(0).trim();
75-
String value = ss.get(1).trim().replaceAll("'", "").trim();
76+
String value = replaceWithQuota(ss.get(1).trim());
7677
propMap.put(key, value);
7778
}
7879

7980
return propMap;
8081
}
8182

83+
private static String replaceWithQuota(String str) {
84+
String removeStart = StringUtils.removeStart(str, "'");
85+
return StringUtils.removeEnd(removeStart, "'");
86+
}
87+
8288
public static class SqlParserResult{
8389

8490
private String tableName;

0 commit comments

Comments
 (0)