fix code

Signed-off-by: xxchan <xxchan22f@gmail.com>

Author: xxchan

src/connector/src/parser/avro/parser.rs

@@ -87,7 +87,7 @@ impl AvroAccessBuilder {
     /// ## Confluent schema registry
     ///
     /// - In Kafka ([Confluent schema registry wire format](https://docs.confluent.io/platform/7.6/schema-registry/fundamentals/serdes-develop/index.html#wire-format)):
-    /// starts with 5 bytes`0x00{schema_id:08x}` followed by Avro binary encoding.
+    ///   starts with 5 bytes`0x00{schema_id:08x}` followed by Avro binary encoding.
     async fn parse_avro_value(&self, payload: &[u8]) -> ConnectorResult<Option<Value>> {
         // parse payload to avro value
         // if use confluent schema, get writer schema from confluent schema registry

src/object_store/src/object/s3.rs

@@ -116,10 +116,7 @@ impl S3StreamingUploader {
         /// Reference: <https://docs.aws.amazon.com/AmazonS3/latest/userguide/qfacts.html>
         const MIN_PART_SIZE: usize = 5 * 1024 * 1024;
         const MAX_PART_SIZE: usize = 5 * 1024 * 1024 * 1024;
-        let part_size = config
-            .upload_part_size
-            .min(MAX_PART_SIZE)
-            .max(MIN_PART_SIZE);
+        let part_size = config.upload_part_size.clamp(MIN_PART_SIZE, MAX_PART_SIZE);
 
         Self {
             client,