From 219b92c8ae6343cc534b7e418d4e712c7f9f7fc1 Mon Sep 17 00:00:00 2001 From: Wei Date: Mon, 31 May 2021 18:52:30 +0800 Subject: [PATCH] [MINOR] The collection can use forEach() directly (#3016) --- .../org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java | 2 +- 1 file changed, 1 insertion(+), 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 1122ced47..cb855c25d 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 @@ -203,7 +203,7 @@ public class HoodieHeartbeatClient implements AutoCloseable, Serializable { * @throws HoodieException */ public void stop() throws HoodieException { - instantToHeartbeatMap.values().stream().forEach(heartbeat -> stop(heartbeat.getInstantTime())); + instantToHeartbeatMap.values().forEach(heartbeat -> stop(heartbeat.getInstantTime())); } public static Long getLastHeartbeatTime(FileSystem fs, String basePath, String instantTime) throws IOException {