You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2024/08/19 05:05:13 UTC

(iotdb) branch 32df6dfc2e3ba created (now 5664f549897)

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

yongzao pushed a change to branch 32df6dfc2e3ba
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 5664f549897 Eventually consistent heartbeat samples #13210

This branch includes the following new commits:

     new 5664f549897 Eventually consistent heartbeat samples #13210

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(iotdb) 01/01: Eventually consistent heartbeat samples #13210

Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

yongzao pushed a commit to branch 32df6dfc2e3ba
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 5664f5498974304f82106bd34e645eb2710aa631
Author: Yongzao <yo...@apache.org>
AuthorDate: Mon Aug 19 12:25:12 2024 +0800

    Eventually consistent heartbeat samples #13210
---
 .../apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
index 01958a589c8..42411e462a1 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
@@ -56,7 +56,7 @@ public abstract class AbstractLoadCache {
       // And un-sequential heartbeats will be discarded.
       if (getLastSample() == null
           || getLastSample().getSampleLogicalTimestamp()
-              < newHeartbeatSample.getSampleLogicalTimestamp()) {
+              <= newHeartbeatSample.getSampleLogicalTimestamp()) {
         slidingWindow.add(newHeartbeatSample);
       }