Skip to content

Commit e95d850

Browse files
committed
Merge branch 'feat_1.8_rowkey' into 'v1.8.0_dev'
修复sonar扫描的问题 See merge request dt-insight-engine/flinkStreamSQL!22
2 parents a91871d + 45197a2 commit e95d850

File tree

3 files changed

+2
-4
lines changed

3 files changed

+2
-4
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ public ReplaceInfo getReplaceInfo(String field){
120120
}
121121

122122
private List<ReplaceInfo> makeFormula(String formula){
123-
if (formula == null || formula.length() <= 0) {
123+
if(formula == null || formula.length() <= 0){
124124
return Lists.newArrayList();
125125
}
126126

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222

2323
import com.dtstack.flink.sql.enums.EUpdateMode;
2424
import com.dtstack.flink.sql.outputformat.AbstractDtRichOutputFormat;
25-
import com.google.common.collect.Lists;
2625
import com.google.common.collect.Maps;
2726
import org.apache.commons.lang3.StringUtils;
2827
import org.apache.flink.api.java.tuple.Tuple2;
@@ -41,7 +40,6 @@
4140
import org.slf4j.LoggerFactory;
4241

4342
import java.io.IOException;
44-
import java.util.List;
4543
import java.util.Map;
4644
import java.util.Set;
4745

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
@@ -130,7 +130,7 @@ public ReplaceInfo getReplaceInfo(String field){
130130

131131
private List<ReplaceInfo> makeFormula(String formula){
132132
if(formula == null || formula.length() <= 0){
133-
Lists.newArrayList();
133+
return Lists.newArrayList();
134134
}
135135
List<ReplaceInfo> result = Lists.newArrayList();
136136
for(String meta: splitIgnoreQuotaBrackets(formula, "\\+")){

0 commit comments

Comments
 (0)