Merge branch 'main' into fix_topk

Author: mergify[bot]

src/query/pipeline/sources/src/processors/sources/input_formats/impls/input_format_tsv.rs

@@ -37,6 +37,7 @@ pub struct InputFormatTSV {}
 impl InputFormatTSV {
     #[allow(clippy::too_many_arguments)]
     fn read_row(
+        field_delimiter: u8,
         field_decoder: &FieldDecoderTSV,
         buf: &[u8],
         deserializers: &mut Vec<common_datavalues::TypeDeserializerImpl>,
@@ -53,7 +54,7 @@ impl InputFormatTSV {
         let mut err_msg = None;
         let buf_len = buf.len();
         while pos <= buf_len {
-            if pos == buf_len || buf[pos] == b'\t' {
+            if pos == buf_len || buf[pos] == field_delimiter {
                 let col_data = &buf[field_start..pos];
                 if col_data.is_empty() {
                     deserializers[column_index].de_default();
@@ -156,6 +157,7 @@ impl InputFormatTextBase for InputFormatTSV {
         for (i, end) in batch.row_ends.iter().enumerate() {
             let buf = &batch.data[start..*end]; // include \n
             Self::read_row(
+                builder.ctx.field_delimiter,
                 field_decoder,
                 buf,
                 columns,

src/query/service/src/servers/mysql/mysql_federated.rs

@@ -242,15 +242,14 @@ impl MySQLFederated {
                 None,
             ),
             ("(?i)^(/\\* ApplicationName=(.*)SHOW VARIABLES(.*))", None),
-            // pt-toolkit
-            ("(?i)^(/\\*!40101 SET(.*) \\*/)$", None),
             // mysqldump 5.7.16
             ("(?i)^(/\\*!40100 SET(.*) \\*/)$", None),
             ("(?i)^(/\\*!40103 SET(.*) \\*/)$", None),
             ("(?i)^(/\\*!40111 SET(.*) \\*/)$", None),
             ("(?i)^(/\\*!40101 SET(.*) \\*/)$", None),
             ("(?i)^(/\\*!40014 SET(.*) \\*/)$", None),
             ("(?i)^(/\\*!40000 SET(.*) \\*/)$", None),
+            ("(?i)^(/\\*!40000 ALTER(.*) \\*/)$", None),
         ];
 
         FederatedHelper::block_match_rule(query, rules)