[Hotfix][Connector-v2][HbaseSink]Fix default timestamp (#4958)

apache · Jun 25, 2023 · 3d8f3bf · 3d8f3bf
1 parent 4db857a
commit 3d8f3bf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java b/...e/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkWriter.java
@@ -112,7 +112,7 @@ public void close() throws IOException {
 
     private Put convertRowToPut(SeaTunnelRow row) {
         byte[] rowkey = getRowkeyFromRow(row);
-        long timestamp = HConstants.LATEST_TIMESTAMP;
+        long timestamp = System.currentTimeMillis();
         if (versionColumnIndex != -1) {
             timestamp = (Long) row.getField(versionColumnIndex);
         }