[iotdb] 02/02: reset CrossSpaceCompactionWriter

[marklau99]

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

marklau99 pushed a commit to branch IOTDB-4423
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 3fa487e460e2887ce6ebbe48e327c8133b7f6c24
Author: Liu Xuxin <liuxu...@outlook.com>
AuthorDate: Tue Sep 27 17:33:56 2022 +0800

    reset CrossSpaceCompactionWriter
---
 .../db/engine/compaction/writer/CrossSpaceCompactionWriter.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
index 373305980f..d192c0f6d7 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
@@ -215,10 +215,10 @@ public class CrossSpaceCompactionWriter extends 
AbstractCompactionWriter {
 
   @Override
   public void updateStartTimeAndEndTime(String device, long time, int 
subTaskId) {
-    int fileIndex = seqFileIndexArray[subTaskId];
-    // we need to synchronized here to avoid multi-thread competition in 
sub-task
-    synchronized (targetTsFileResources.get(fileIndex)) {
+    synchronized (this) {
+      int fileIndex = seqFileIndexArray[subTaskId];
       TsFileResource resource = targetTsFileResources.get(fileIndex);
+      // we need to synchronized here to avoid multi-thread competition in 
sub-task
       resource.updateStartTime(device, time);
       resource.updateEndTime(device, time);
     }