You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/10/17 01:00:52 UTC
(iotdb) branch FollowerRead updated: Support a new read_consistency_level
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch FollowerRead
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/FollowerRead by this push:
new 2ca4436907a Support a new read_consistency_level
2ca4436907a is described below
commit 2ca4436907a38a6fff3e8de7b70698b8807e55bf
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Oct 17 09:00:43 2025 +0800
Support a new read_consistency_level
---
.../java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
index 0ea7a278732..9f6d7b58793 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
@@ -359,7 +359,9 @@ public class ConfigNodeDescriptor {
String readConsistencyLevel =
properties.getProperty("read_consistency_level", conf.getReadConsistencyLevel());
- if (readConsistencyLevel.equals("strong") || readConsistencyLevel.equals("weak")) {
+ if (readConsistencyLevel.equalsIgnoreCase("strong")
+ || readConsistencyLevel.equalsIgnoreCase("weak")
+ || readConsistencyLevel.equalsIgnoreCase("follower_read")) {
conf.setReadConsistencyLevel(readConsistencyLevel);
} else {
throw new IOException(