Skip to content

Commit ee766b8

Browse files
author
dapeng
committed
fix 缓存时间没有解析的问题
1 parent dfea94b commit ee766b8

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/HbaseAsyncReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ public void asyncInvoke(CRow input, ResultFuture<CRow> resultFuture) throws Exce
148148
return;
149149
} else if (ECacheContentType.SingleLine == val.getType()) {
150150
try {
151-
Row row = fillData(inputCopy.row(), val);
151+
Row row = fillData(inputCopy.row(), val.getContent());
152152
resultFuture.complete(Collections.singleton(new CRow(row, inputCopy.change())));
153153
} catch (Exception e) {
154154
dealFillDataError(resultFuture, e, inputCopy);

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ public HbaseSideParser() {
6161
public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, Object> props) {
6262
HbaseSideTableInfo hbaseTableInfo = new HbaseSideTableInfo();
6363
hbaseTableInfo.setName(tableName);
64+
parseCacheProp(hbaseTableInfo, props);
6465
parseFieldsInfo(fieldsInfo, hbaseTableInfo);
6566
hbaseTableInfo.setTableName((String) props.get(TABLE_NAME_KEY.toLowerCase()));
6667
hbaseTableInfo.setParallelism(MathUtil.getIntegerVal(props.get(PARALLELISM_KEY.toLowerCase())));

0 commit comments

Comments
 (0)