| commit | ba853b3147b3d13911c08bf2f39fcc6e3ee88f7f | [log] [tgz] |
|---|---|---|
| author | Caideyipi <87789683+Caideyipi@users.noreply.github.com> | Mon Apr 22 17:53:05 2024 +0800 |
| committer | GitHub <noreply@github.com> | Mon Apr 22 17:53:05 2024 +0800 |
| tree | 243345feb0d633241cb2276de800550d8dd5b06b | |
| parent | d83723feee8530ffe537df6e5f746a1392126c54 [diff] |
Pipe: Fixed the bug that aggregate processor cannot clear the last received time after drop (#12383)
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 49508f7..4d19195 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 @@ == 0) { pipeName2timeSeries2TimeSeriesRuntimeStateMap.get(pipeName).clear(); pipeName2timeSeries2TimeSeriesRuntimeStateMap.remove(pipeName); + pipeName2LastValueReceiveTimeMap.remove(pipeName); } if (Objects.nonNull(windowingProcessor)) { windowingProcessor.close();