update

Author: zhyass

scripts/selfhost/restore_logs.sh

@@ -2,40 +2,40 @@
 
 # Parse arguments
 while [[ $# -gt 0 ]]; do
-    case "$1" in
-        --dsn)
-            DSN="$2"
-            shift 2
-            ;;
-        --stage)
-            STAGE="$2"
-            shift 2
-            ;;
-        *)
-            if [[ "$1" =~ ^[0-9]{8}$ ]]; then
-                DATE_ARG="$1"
-                shift
-            else
-                echo "Unknown parameter: $1"
-                exit 1
-            fi
-            ;;
-    esac
+	case "$1" in
+	--dsn)
+		DSN="$2"
+		shift 2
+		;;
+	--stage)
+		STAGE="$2"
+		shift 2
+		;;
+	*)
+		if [[ "$1" =~ ^[0-9]{8}$ ]]; then
+			DATE_ARG="$1"
+			shift
+		else
+			echo "Unknown parameter: $1"
+			exit 1
+		fi
+		;;
+	esac
 done
 
 # Check required parameters
 if [[ -z "$STAGE" || -z "$DATE_ARG" ]]; then
-    echo "Missing required parameters: --stage or yyyymmdd date"
-    exit 1
+	echo "Missing required parameters: --stage or yyyymmdd date"
+	exit 1
 fi
 
 # If DSN not provided, try to get from environment variable
 if [[ -z "$DSN" ]]; then
-    DSN="$BENDSQL_DSN"
-    if [[ -z "$DSN" ]]; then
-        echo "--dsn parameter not provided and BENDSQL_DSN environment variable not set"
-        exit 1
-    fi
+	DSN="$BENDSQL_DSN"
+	if [[ -z "$DSN" ]]; then
+		echo "--dsn parameter not provided and BENDSQL_DSN environment variable not set"
+		exit 1
+	fi
 fi
 
 # Format date
@@ -49,8 +49,8 @@ DOWNLOAD_SQL="PRESIGN DOWNLOAD @${STAGE}/data_${FORMATTED_DATE}.tar.gz"
 DOWNLOAD_URL=$(bendsql --dsn "${DSN}" --query="${DOWNLOAD_SQL}" | awk '{print $3}')
 
 if [[ -z "$DOWNLOAD_URL" ]]; then
-    echo "Failed to get download URL"
-    exit 1
+	echo "Failed to get download URL"
+	exit 1
 fi
 
 # 2. Download the file
@@ -59,8 +59,8 @@ echo "Downloading file: ${TAR_FILE}"
 curl -o "${TAR_FILE}" "${DOWNLOAD_URL}"
 
 if [[ ! -f "${TAR_FILE}" ]]; then
-    echo "File download failed"
-    exit 1
+	echo "File download failed"
+	exit 1
 fi
 
 # 3. Extract the file
@@ -76,25 +76,25 @@ bendsql --dsn "${DSN}" --query="DROP STAGE IF EXISTS ${UPLOAD_STAGE}"
 bendsql --dsn "${DSN}" --query="CREATE STAGE ${UPLOAD_STAGE}"
 
 find "${TEMP_DIR}" -type f | while read -r FILE; do
-    RELATIVE_PATH="${FILE#${TEMP_DIR}/}"
+	RELATIVE_PATH="${FILE#${TEMP_DIR}/}"
 
-    # Get upload presigned URL
-    UPLOAD_SQL="PRESIGN UPLOAD @${UPLOAD_STAGE}/${RELATIVE_PATH}"
-    UPLOAD_URL=$(bendsql --dsn "${DSN}" --query="${UPLOAD_SQL}" | awk '{print $3}')
+	# Get upload presigned URL
+	UPLOAD_SQL="PRESIGN UPLOAD @${UPLOAD_STAGE}/${RELATIVE_PATH}"
+	UPLOAD_URL=$(bendsql --dsn "${DSN}" --query="${UPLOAD_SQL}" | awk '{print $3}')
 
-    if [[ -z "$UPLOAD_URL" ]]; then
-        echo "Failed to get upload URL for: ${RELATIVE_PATH}"
-        continue
-    fi
+	if [[ -z "$UPLOAD_URL" ]]; then
+		echo "Failed to get upload URL for: ${RELATIVE_PATH}"
+		continue
+	fi
 
-    echo "Uploading file: ${RELATIVE_PATH}"
-    curl -X PUT -T "${FILE}" "${UPLOAD_URL}"
+	echo "Uploading file: ${RELATIVE_PATH}"
+	curl -X PUT -T "${FILE}" "${UPLOAD_URL}"
 
-    if [[ $? -eq 0 ]]; then
-        echo "Upload successful: ${RELATIVE_PATH}"
-    else
-        echo "Upload failed: ${RELATIVE_PATH}"
-    fi
+	if [[ $? -eq 0 ]]; then
+		echo "Upload successful: ${RELATIVE_PATH}"
+	else
+		echo "Upload failed: ${RELATIVE_PATH}"
+	fi
 done
 
 # Cleanup temporary files
@@ -132,4 +132,4 @@ bendsql --dsn "${DSN}" --database "${RESTORE_DATABASE}" --query="create table pr
 bendsql --dsn "${DSN}" --database "${RESTORE_DATABASE}" --query="COPY INTO profile_history FROM @${UPLOAD_STAGE}/query_profile_logs;"
 echo "The '${RESTORE_DATABASE}.profile_history' table has been successfully restored"
 
-echo "Processing completed"
+echo "Processing completed"

src/query/service/tests/it/storages/fuse/operations/mutation/segments_compact_mutator.rs

@@ -781,7 +781,7 @@ impl CompactSegmentTestFixture {
                         None,
                         None,
                         None,
-            None,
+                        None,
                         Compression::Lz4Raw,
                         Some(Utc::now()),
                     );