fixed

Author: sunxiaojian

api/src/main/java/org/apache/gravitino/rel/expressions/distributions/Distributions.java

@@ -26,6 +26,8 @@
 /** Helper methods to create distributions to pass into Apache Gravitino. */
 public class Distributions {
 
+  public static final int AUTO = -1;
+
   /** NONE is used to indicate that there is no distribution. */
   public static final Distribution NONE =
       new DistributionImpl(Strategy.NONE, 0, Expression.EMPTY_EXPRESSION);
@@ -82,7 +84,7 @@ public static Distribution of(Strategy strategy, int number, Expression... expre
    * @return The created distribution
    */
   public static Distribution auto(Strategy strategy, Expression... expressions) {
-    return new DistributionImpl(strategy, -1, expressions);
+    return new DistributionImpl(strategy, AUTO, expressions);
   }
 
   /**

catalogs/catalog-jdbc-doris/src/main/java/org/apache/gravitino/catalog/doris/operation/DorisTableOperations.java

@@ -134,9 +134,7 @@ protected String generateCreateTableSql(
     }
 
     if (distribution.number() != 0) {
-      sqlBuilder
-          .append(" BUCKETS ")
-          .append(DorisUtils.revertDistributionBucket(distribution.number()));
+      sqlBuilder.append(" BUCKETS ").append(DorisUtils.toBucketNumberString(distribution.number()));
     }
 
     properties = appendNecessaryProperties(properties);

catalogs/catalog-jdbc-doris/src/main/java/org/apache/gravitino/catalog/doris/utils/DorisUtils.java

@@ -29,6 +29,7 @@
 import java.util.stream.Collectors;
 import org.apache.gravitino.rel.expressions.NamedReference;
 import org.apache.gravitino.rel.expressions.distributions.Distribution;
+import org.apache.gravitino.rel.expressions.distributions.Distributions;
 import org.apache.gravitino.rel.expressions.distributions.Distributions.DistributionImpl;
 import org.apache.gravitino.rel.expressions.distributions.Strategy;
 import org.apache.gravitino.rel.expressions.literals.Literal;
@@ -222,21 +223,16 @@ private static int extractBucketNum(Matcher matcher) {
     int bucketNum = 1;
     if (matcher.find(5)) {
       String bucketValue = matcher.group(5);
-      if (bucketValue.trim().toUpperCase().equals("AUTO")) {
-        // Use -1 to indicate auto bucket.
-        bucketNum = -1;
-      } else {
-        bucketNum = Integer.valueOf(matcher.group(5));
-      }
+      // Use -1 to indicate auto bucket.
+      bucketNum =
+          bucketValue.trim().toUpperCase().equals("AUTO")
+              ? Distributions.AUTO
+              : Integer.valueOf(bucketValue);
     }
     return bucketNum;
   }
 
-  public static String revertDistributionBucket(int number) {
-    if (number == -1) {
-      return "AUTO";
-    } else {
-      return String.valueOf(number);
-    }
+  public static String toBucketNumberString(int number) {
+    return number == Distributions.AUTO ? "AUTO" : String.valueOf(number);
   }
 }