[hive] branch master updated: HIVE-26341: Replication logs & metrics shows last repl id as 0 when number of events is zero (Haymant Mangla, reviewed by Rajesh Balamohan and Mahesh Kumar Behera)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mahesh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 248ce4aa5ee HIVE-26341: Replication logs & metrics shows last repl id as 0 when number of events is zero (Haymant Mangla, reviewed by  Rajesh Balamohan and Mahesh Kumar Behera)
248ce4aa5ee is described below

commit 248ce4aa5ee079850b9d81e737493a1309485521
Author: Haymant Mangla <79...@users.noreply.github.com>
AuthorDate: Tue Jun 21 10:07:09 2022 +0530

    HIVE-26341: Replication logs & metrics shows last repl id as 0 when number of events is zero (Haymant Mangla, reviewed by  Rajesh Balamohan and Mahesh Kumar Behera)
---
 .../hive/ql/exec/repl/incremental/IncrementalLoadTasksBuilder.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/incremental/IncrementalLoadTasksBuilder.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/incremental/IncrementalLoadTasksBuilder.java
index c9f0da41678..c5f6d6ed2f2 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/incremental/IncrementalLoadTasksBuilder.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/incremental/IncrementalLoadTasksBuilder.java
@@ -176,7 +176,8 @@ public class IncrementalLoadTasksBuilder {
       taskChainTail = updateIncPendTask;
 
       Map<String, String> dbProps = new HashMap<>();
-      dbProps.put(ReplicationSpec.KEY.CURR_STATE_ID_SOURCE.toString(), String.valueOf(lastReplayedEvent));
+      dbProps.put(ReplicationSpec.KEY.CURR_STATE_ID_SOURCE.toString(),
+              String.valueOf((lastReplayedEvent == null) ? eventTo : lastReplayedEvent));
       ReplStateLogWork replStateLogWork = new ReplStateLogWork(replLogger, dbProps, dumpDirectory,
               metricCollector, shouldFailover);
       Task<?> barrierTask = TaskFactory.get(replStateLogWork, conf);