Skip to content

Commit 64c00d3

Browse files
author
gituser
committed
Merge branch 'hotfix_1.10_4.0.x_29910' into 1.10_release_4.0.x
2 parents 9252830 + e76a921 commit 64c00d3

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

docs/plugin/hbaseSink.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ CREATE TABLE MyResult(
77
type ='hbase',
88
zookeeperQuorum ='ip:port[,ip:port]',
99
tableName ='tableName',
10-
rowKey ='colName[,colName]',
10+
rowKey ='colName[+colName]',
1111
parallelism ='1',
1212
zookeeperParent ='/hbase'
1313
)
@@ -34,7 +34,7 @@ hbase2.0
3434
|zookeeperQuorum | hbase zk地址,多个直接用逗号隔开|||
3535
|zookeeperParent | zkParent 路径|||
3636
|tableName | 关联的hbase表名称|||
37-
|rowkey | hbase的rowkey关联的列信息,多个值以逗号隔开|||
37+
|rowkey | hbase的rowkey关联的列信息'+'多个值以逗号隔开|||
3838
|updateMode|APPEND:不回撤数据,只下发增量数据,UPSERT:先删除回撤数据,然后更新|否|APPEND|
3939
|parallelism | 并行度设置||1|
4040
|kerberosAuthEnable | 是否开启kerberos认证||false|
@@ -76,7 +76,7 @@ CREATE TABLE MyResult(
7676
tableName ='myresult',
7777
partitionedJoin ='false',
7878
parallelism ='1',
79-
rowKey='name,channel'
79+
rowKey='name+channel'
8080
);
8181
8282
insert
@@ -141,7 +141,7 @@ into
141141

142142
## 6.hbase数据
143143
### 数据内容说明
144-
hbase的rowkey 构建规则:以描述的rowkey字段值作为key,多个字段以'-'连接
144+
hbase的rowkey 构建规则:以描述的rowkey字段值作为key,多个字段以'+'连接
145145
### 数据内容示例
146146
hbase(main):007:0> scan 'myresult'
147147
ROW COLUMN+CELL

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -110,10 +110,6 @@ public static String[] splitIgnoreQuotaBrackets(String str, String delimiter){
110110
public ReplaceInfo getReplaceInfo(String field){
111111

112112
field = field.trim();
113-
if(field.length() <= 0){
114-
throw new RuntimeException(field + " \n" +
115-
"Format defined exceptions");
116-
}
117113

118114
//判断是不是常量==>''包裹的标识
119115
if(field.startsWith("'") && field.endsWith("'")){

0 commit comments

Comments
 (0)