1
0

[MINOR] Access the static member getLastHeartbeatTime via the class instead (#3015)

This commit is contained in:
Wei
2021-05-31 18:54:05 +08:00
committed by GitHub
parent 219b92c8ae
commit e6a71ea544

View File

@@ -93,7 +93,7 @@ public class HeartbeatUtils {
try {
if (config.getFailedWritesCleanPolicy().isLazy() && heartbeatClient.isHeartbeatExpired(instantTime)) {
throw new HoodieException("Heartbeat for instant " + instantTime + " has expired, last heartbeat "
+ heartbeatClient.getLastHeartbeatTime(table.getMetaClient().getFs(), config.getBasePath(), instantTime));
+ HoodieHeartbeatClient.getLastHeartbeatTime(table.getMetaClient().getFs(), config.getBasePath(), instantTime));
}
} catch (IOException io) {
throw new HoodieException("Unable to read heartbeat", io);