This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch optimize_dispatch_read_only_log in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 55d2711d07dcdb4f397a8c46be84e0d088aa7a78 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Mon Jan 15 11:49:02 2024 +0800 finish Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../plan/scheduler/FragmentInstanceDispatcherImpl.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java index a1ab241fa6a..41e370cf0e6 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java @@ -389,10 +389,13 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { RegionWriteExecutor writeExecutor = new RegionWriteExecutor(); RegionExecutionResult writeResult = writeExecutor.execute(groupId, planNode); if (!writeResult.isAccepted()) { - logger.warn( - "write locally failed. TSStatus: {}, message: {}", - writeResult.getStatus(), - writeResult.getMessage()); + // DO NOT LOG READ_ONLY ERROR + if (writeResult.getStatus().getCode() != TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()) { + logger.warn( + "write locally failed. TSStatus: {}, message: {}", + writeResult.getStatus(), + writeResult.getMessage()); + } if (writeResult.getStatus() == null) { throw new FragmentInstanceDispatchException( RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, writeResult.getMessage()));
