Skip to content

Commit 7cd2943

Browse files
committed
Update SimpleConsensus.java
1 parent 5700de6 commit 7cd2943

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,8 @@ public TSStatus write(ConsensusGroupId groupId, IConsensusRequest request)
119119
SimpleConsensusServerImpl impl =
120120
Optional.ofNullable(stateMachineMap.get(groupId))
121121
.orElseThrow(() -> new ConsensusGroupNotExistException(groupId));
122-
if (impl.isReadOnly()) {
122+
// Schema Write when readOnly is handled at RegionWriteExecutor
123+
if (impl.isReadOnly() && groupId instanceof DataRegionId) {
123124
return StatusUtils.getStatus(TSStatusCode.SYSTEM_READ_ONLY);
124125
} else {
125126
TSStatus status;

0 commit comments

Comments
 (0)