[fix][dingo-calcite] Fix the error message issue for alterTableColumn

Author: guojn1

dingo-calcite/src/main/java/io/dingodb/calcite/DingoDdlExecutor.java

@@ -1749,6 +1749,9 @@ public void execute(SqlAlterChangeColumn sqlAlterChangeColumn, CalcitePrepare.Co
             }
         }
         DingoSqlColumn dingoSqlColumn = sqlAlterChangeColumn.dingoSqlColumn;
+        if (dingoSqlColumn == null) {
+            throw DingoErrUtil.newStdErr(ErrNotSupportedYet);
+        }
         String name = dingoSqlColumn.name.getSimple();
         Column column = table.getColumns().stream()
             .filter(col -> col.getSchemaState() == SchemaState.SCHEMA_PUBLIC

dingo-exec/src/main/java/io/dingodb/exec/operator/DistributeOperator.java

@@ -19,6 +19,7 @@
 import io.dingodb.codec.CodecService;
 import io.dingodb.codec.KeyValueCodec;
 import io.dingodb.common.CommonId;
+import io.dingodb.common.log.LogUtils;
 import io.dingodb.common.partition.RangeDistribution;
 import io.dingodb.common.util.ByteArrayUtils;
 import io.dingodb.common.util.Optional;
@@ -88,6 +89,9 @@ public boolean push(Context context, @Nullable Object[] tuple, Vertex vertex) {
             KeyValueCodec indexCodec = CodecService.getDefault()
                 .createKeyValueCodec(indexTable.getCodecVersion(), indexTable.version,
                     indexTable.tupleType(), indexTable.keyMapping());
+            if (param.getDistributions().isEmpty() && "replicaTable".equalsIgnoreCase(indexTable.getName())) {
+                return true;
+            }
             partId = indexPs.calcPartId(indexTuple, wrap(indexCodec::encodeKey), param.getDistributions());
             NavigableMap<ByteArrayUtils.ComparableByteArray, RangeDistribution> distribution =
                 MetaService.root().getRangeDistribution(param.getTable().tableId);