Skip to content

Commit 00262ed

Browse files
author
gituser
committed
Merge branch 'hotfix_1.10_4.0.x_30197' into 1.10_release_4.0.x
2 parents 6a0d087 + 97fcbde commit 00262ed

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

hbase/hbase-side/hbase-side-core/src/main/java/com/dtstack/flink/sql/side/hbase/RowKeyBuilder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ private String buildStr(List<ReplaceInfo> fieldList, Map<String, Object> refData
6565
if(CollectionUtils.isEmpty(fieldList)){
6666
return "";
6767
}
68-
StringBuffer sb = new StringBuffer("");
68+
StringBuilder sb = new StringBuilder("");
6969
for(ReplaceInfo replaceInfo : fieldList){
7070

7171
if(replaceInfo.getType() == EReplaceType.CONSTANT){
@@ -101,7 +101,7 @@ public static String[] splitIgnoreQuotaBrackets(String str, String delimiter){
101101
public ReplaceInfo getReplaceInfo(String field){
102102

103103
field = field.trim();
104-
if(field.length() <= 2){
104+
if(field.length() <= 0){
105105
throw new RuntimeException(field + " \n" +
106106
"Format defined exceptions");
107107
}

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/RowKeyBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public static String[] splitIgnoreQuotaBrackets(String str, String delimiter){
110110
public ReplaceInfo getReplaceInfo(String field){
111111

112112
field = field.trim();
113-
if(field.length() <= 2){
113+
if(field.length() <= 0){
114114
throw new RuntimeException(field + " \n" +
115115
"Format defined exceptions");
116116
}

0 commit comments

Comments
 (0)