remove print

fix

fmt

java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraUtil.java

@@ -81,7 +81,8 @@ public static void checkSchema(
             Map<CqlIdentifier, ColumnMetadata> cassandraColumnDescMap) {
         if (columnDescs.size() > cassandraColumnDescMap.size()) {
             throw Status.FAILED_PRECONDITION
-                    .withDescription("Don't match in the number of columns in the table")
+                    .withDescription(
+                            "The columns of the sink must be equal to or a superset of the target table's columns.")
                     .asRuntimeException();
         }
         for (ColumnDesc columnDesc : columnDescs) {

src/connector/src/sink/clickhouse.rs

@@ -261,7 +261,7 @@ impl ClickHouseSink {
             .collect();
 
         if rw_fields_name.len().gt(&clickhouse_columns_desc.len()) {
-            return Err(SinkError::ClickHouse("The nums of the RisingWave column must be greater than/equal to the length of the Clickhouse column".to_string()));
+            return Err(SinkError::ClickHouse("The columns of the sink must be equal to or a superset of the target table's columns.".to_string()));
         }
 
         for i in rw_fields_name {

src/connector/src/sink/doris.rs

@@ -129,7 +129,7 @@ impl DorisSink {
         let rw_fields_name = self.schema.fields();
         if rw_fields_name.len().gt(&doris_columns_desc.len()) {
             return Err(SinkError::Doris(
-                "The length of the RisingWave column must be le the length of the doris column"
+                "The columns of the sink must be equal to or a superset of the target table's columns."
                     .to_string(),
             ));
         }

src/connector/src/sink/doris_starrocks_connector.rs

@@ -162,7 +162,6 @@ impl HeaderBuilder {
     }
 
     pub fn build(self) -> HashMap<String, String> {
-        println!("{:?}", self.header);
         self.header
     }
 }

src/connector/src/sink/starrocks.rs

@@ -128,7 +128,7 @@ impl StarrocksSink {
     ) -> Result<()> {
         let rw_fields_name = self.schema.fields();
         if rw_fields_name.len() > starrocks_columns_desc.len() {
-            return Err(SinkError::Starrocks("The length of the RisingWave column must be equal or less to the length of the starrocks column".to_string()));
+            return Err(SinkError::Starrocks("The columns of the sink must be equal to or a superset of the target table's columns.".to_string()));
         }
 
         for i in rw_fields_name {

src/connector/with_options_sink.yaml

@@ -127,6 +127,9 @@ DorisConfig:
   - name: doris.table
     field_type: String
     required: true
+  - name: doris.partial_columns
+    field_type: String
+    required: false
   - name: r#type
     field_type: String
     required: true