Update DataNodeSchemaLockManager.java

Caideyipi · Caideyipi · commit 1f4df53397d4 · 2025-03-19T19:46:50.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/lock/DataNodeSchemaLockManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/lock/DataNodeSchemaLockManager.java
@@ -39,7 +39,7 @@ private DataNodeSchemaLockManager() {
     final int lockNum = SchemaLockType.values().length;
     this.locks = new ReentrantReadWriteLock[lockNum];
     for (int i = 0; i < lockNum; i++) {
-      locks[i] = new ReentrantReadWriteLock(false);
+      locks[i] = new ReentrantReadWriteLock(true);
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ private DataNodeSchemaLockManager() {`
`39`	`39`	`final int lockNum = SchemaLockType.values().length;`
`40`	`40`	`this.locks = new ReentrantReadWriteLock[lockNum];`
`41`	`41`	`for (int i = 0; i < lockNum; i++) {`
`42`		`- locks[i] = new ReentrantReadWriteLock(false);`
	`42`	`+ locks[i] = new ReentrantReadWriteLock(true);`
`43`	`43`	`}`
`44`	`44`	`}`
`45`	`45`