[hudi] branch master updated: [MINOR] Fix spark sql run clean do not exit (#7918)

[leesf]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 91505853144 [MINOR] Fix spark sql run clean do not exit (#7918)
91505853144 is described below

commit 9150585314470390ca1b1a77f0419f1a640766de
Author: StreamingFlames <18889897...@163.com>
AuthorDate: Thu Feb 16 17:46:07 2023 +0800

    [MINOR] Fix spark sql run clean do not exit (#7918)
---
 .../java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java
index 50d83bb1398..7201aad0a18 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java
@@ -84,7 +84,7 @@ public class HoodieHeartbeatClient implements AutoCloseable, 
Serializable {
     private Boolean isHeartbeatStopped = false;
     private Long lastHeartbeatTime;
     private Integer numHeartbeats = 0;
-    private Timer timer = new Timer();
+    private Timer timer = new Timer(true);
 
     public String getInstantTime() {
       return instantTime;
@@ -226,6 +226,7 @@ public class HoodieHeartbeatClient implements 
AutoCloseable, Serializable {
       lastHeartbeatForWriter = new Heartbeat();
       lastHeartbeatForWriter.setLastHeartbeatTime(lastHeartbeatForWriterTime);
       lastHeartbeatForWriter.setInstantTime(instantTime);
+      lastHeartbeatForWriter.getTimer().cancel();
     }
     if (currentTime - lastHeartbeatForWriter.getLastHeartbeatTime() > 
this.maxAllowableHeartbeatIntervalInMs) {
       LOG.warn("Heartbeat expired, currentTime = " + currentTime + ", last 
heartbeat = " + lastHeartbeatForWriter