From 415b9591bff31d7ccad4cbf3a39790b9932351c9 Mon Sep 17 00:00:00 2001 From: liumengkai <1623857502@qq.com> Date: Thu, 12 Jan 2023 21:07:38 +0800 Subject: [PATCH] [BugFix][hbse-connector][#1485] hbase ttl millisecond not second --- .../connector/hbase/converter/HBaseColumnConverter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/chunjun-connectors/chunjun-connector-hbase-base/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java b/chunjun-connectors/chunjun-connector-hbase-base/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java index 132fd94cd9..d020bb8a98 100644 --- a/chunjun-connectors/chunjun-connector-hbase-base/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java +++ b/chunjun-connectors/chunjun-connector-hbase-base/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java @@ -213,7 +213,8 @@ public Mutation toExternal(RowData rowData, Mutation output) throws Exception { } put.setTTL( - Optional.ofNullable(hBaseConf.getTtl()).orElseGet(() -> (long) Integer.MAX_VALUE)); + Optional.ofNullable(hBaseConf.getTtl()) + .orElseGet(() -> (long) Integer.MAX_VALUE * 1000)); for (int i = 0; i < rowData.getArity(); i++) { if (rowKeyIndex == i || columnConfigIndex.contains(i)) {