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 <[email protected]>
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(

Reply via email to