(iotdb) branch master updated: Pipe: Fixed the bug that aggregate processor cannot clear the last received time after drop (#12383)

[rong]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ba853b3147b Pipe: Fixed the bug that aggregate processor cannot clear 
the last received time after drop (#12383)
ba853b3147b is described below

commit ba853b3147b3d13911c08bf2f39fcc6e3ee88f7f
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Apr 22 17:53:05 2024 +0800

    Pipe: Fixed the bug that aggregate processor cannot clear the last received 
time after drop (#12383)
---
 .../org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java
index 49508f74b0f..4d19195e0f4 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java
@@ -773,6 +773,7 @@ public class AggregateProcessor implements PipeProcessor {
             == 0) {
       pipeName2timeSeries2TimeSeriesRuntimeStateMap.get(pipeName).clear();
       pipeName2timeSeries2TimeSeriesRuntimeStateMap.remove(pipeName);
+      pipeName2LastValueReceiveTimeMap.remove(pipeName);
     }
     if (Objects.nonNull(windowingProcessor)) {
       windowingProcessor.close();