Update TableConfigTaskVisitor.java

apache · Nov 29, 2024 · 2203d98 · 2203d98
1 parent 54f7a59
commit 2203d98
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...in/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java b/...in/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java
@@ -123,6 +123,7 @@
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.StopPipe;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Use;
 import org.apache.iotdb.db.queryengine.plan.relational.type.TypeNotFoundException;
+import org.apache.iotdb.db.queryengine.plan.statement.metadata.DatabaseSchemaStatement;
 import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowClusterStatement;
 import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowRegionStatement;
 import org.apache.iotdb.db.queryengine.plan.statement.sys.FlushStatement;
@@ -191,11 +192,15 @@ protected IConfigTask visitCreateOrAlterDB(
       final String key = property.getName().getValue().toLowerCase(Locale.ENGLISH);
       if (property.isSetToDefault()) {
         switch (key) {
-          case TTL_KEY:
           case TIME_PARTITION_INTERVAL_KEY:
           case SCHEMA_REGION_GROUP_NUM_KEY:
           case DATA_REGION_GROUP_NUM_KEY:
             break;
+          case TTL_KEY:
+            if (node.getType() == DatabaseSchemaStatement.DatabaseSchemaStatementType.ALTER) {
+              schema.setTTL(Long.MAX_VALUE);
+            }
+            break;
           default:
             throw new SemanticException("Unsupported database property key: " + key);
         }
@@ -212,6 +217,9 @@ protected IConfigTask visitCreateOrAlterDB(
               throw new SemanticException(
                   "ttl value must be 'INF' or a long literal, but now is: " + value);
             }
+            if (node.getType() == DatabaseSchemaStatement.DatabaseSchemaStatementType.ALTER) {
+              schema.setTTL(Long.MAX_VALUE);
+            }
             break;
           }
           schema.setTTL(parseLongFromLiteral(value, TTL_KEY));