[fix][hbase] rowKey not available.
@@ -20,6 +20,7 @@ package com.dtstack.flink.sql.parser;
import com.dtstack.flink.sql.util.DtStringUtil;
import com.google.common.collect.Maps;
+import org.apache.commons.lang3.StringUtils;
import java.util.List;
import java.util.Map;
@@ -72,13 +73,18 @@ public class CreateTableParser implements IParser {
for (String str : strings) {
List<String> ss = DtStringUtil.splitIgnoreQuota(str, '=');
String key = ss.get(0).trim();
- String value = ss.get(1).trim().replaceAll("'", "").trim();
+ String value = replaceWithQuota(ss.get(1).trim());
propMap.put(key, value);
}
return propMap;
}
+ private static String replaceWithQuota(String str) {
+ String removeStart = StringUtils.removeStart(str, "'");
+ return StringUtils.removeEnd(removeStart, "'");
+ }
+
public static class SqlParserResult{
private String tableName;
