Merge 'master' into ncb/fix-client-replxx-crash

bharatnc · bharatnc · commit 957e19c0e960 · 2025-07-23T18:43:45.000-07:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
diff --git a/contrib/curl b/contrib/curl
@@ -1 +1 @@
-Subproject commit 4dacb79fcdd9364c1083e06f6a011d797a344f47
+Subproject commit cfbfb65047e85e6b08af65fe9cdbcf68e9ad496a
diff --git a/contrib/curl-cmake/CMakeLists.txt b/contrib/curl-cmake/CMakeLists.txt
@@ -81,7 +81,6 @@ set (SRCS
     "${LIBRARY_DIR}/lib/idn.c"
     "${LIBRARY_DIR}/lib/if2ip.c"
     "${LIBRARY_DIR}/lib/imap.c"
-    "${LIBRARY_DIR}/lib/inet_ntop.c"
     "${LIBRARY_DIR}/lib/krb5.c"
     "${LIBRARY_DIR}/lib/ldap.c"
     "${LIBRARY_DIR}/lib/llist.c"
@@ -148,13 +147,12 @@ set (SRCS
     "${LIBRARY_DIR}/lib/vauth/oauth2.c"
     "${LIBRARY_DIR}/lib/vauth/spnego_gssapi.c"
     "${LIBRARY_DIR}/lib/vauth/spnego_sspi.c"
-    "${LIBRARY_DIR}/lib/vauth/vauth.c"    
+    "${LIBRARY_DIR}/lib/vauth/vauth.c"
     "${LIBRARY_DIR}/lib/vquic/vquic.c"
     "${LIBRARY_DIR}/lib/vssh/curl_path.c"
     "${LIBRARY_DIR}/lib/vssh/libssh.c"
     "${LIBRARY_DIR}/lib/vssh/libssh2.c"
 
-    "${LIBRARY_DIR}/lib/vtls/bearssl.c"
     "${LIBRARY_DIR}/lib/vtls/cipher_suite.c"
     "${LIBRARY_DIR}/lib/vtls/gtls.c"
     "${LIBRARY_DIR}/lib/vtls/hostcheck.c"
@@ -165,14 +163,14 @@ set (SRCS
     "${LIBRARY_DIR}/lib/vtls/rustls.c"
     "${LIBRARY_DIR}/lib/vtls/schannel.c"
     "${LIBRARY_DIR}/lib/vtls/schannel_verify.c"
-    "${LIBRARY_DIR}/lib/vtls/sectransp.c"
     "${LIBRARY_DIR}/lib/vtls/vtls.c"
     "${LIBRARY_DIR}/lib/vtls/vtls_scache.c"
     "${LIBRARY_DIR}/lib/vtls/vtls_spack.c"
     "${LIBRARY_DIR}/lib/vtls/wolfssl.c"
     "${LIBRARY_DIR}/lib/vtls/x509asn1.c"
     "${LIBRARY_DIR}/lib/curlx/base64.c"
     "${LIBRARY_DIR}/lib/curlx/dynbuf.c"
+    "${LIBRARY_DIR}/lib/curlx/inet_ntop.c"
     "${LIBRARY_DIR}/lib/curlx/inet_pton.c"
     "${LIBRARY_DIR}/lib/curlx/multibyte.c"
     "${LIBRARY_DIR}/lib/curlx/nonblock.c"
@@ -181,6 +179,7 @@ set (SRCS
     "${LIBRARY_DIR}/lib/curlx/timeval.c"
     "${LIBRARY_DIR}/lib/curlx/version_win32.c"
     "${LIBRARY_DIR}/lib/curlx/warnless.c"
+    "${LIBRARY_DIR}/lib/curlx/wait.c"
     "${LIBRARY_DIR}/lib/curlx/winapi.c"
 )
 
diff --git a/contrib/curl-cmake/curl_config.h b/contrib/curl-cmake/curl_config.h
@@ -16,6 +16,7 @@
 #define HAVE_GETADDRINFO
 #define HAVE_LONGLONG
 #define HAVE_POLL_FINE
+#define HAVE_SELECT
 #define HAVE_SIGACTION
 #define HAVE_SIGNAL
 #define HAVE_SIGSETJMP
@@ -44,8 +45,9 @@
 #define HAVE_FCNTL_H
 #define HAVE_NETDB_H
 #define HAVE_NETINET_IN_H
+#define HAVE_SELECT_H
+#define HAVE_SETJMP_H
 #define HAVE_SETJMP_H
-#define HAVE_SYS_STAT_H
 #define HAVE_UNISTD_H
 #define HAVE_POLL_H
 #define HAVE_PTHREAD_H
diff --git a/flake.nix b/flake.nix
@@ -142,7 +142,7 @@
     contrib-aws-c-event-stream = { url = "github:awslabs/aws-c-event-stream/08f24e384e5be20bcffa42b49213d24dad7881ae"; flake = false; };
     contrib-aws-c-common = { url = "github:awslabs/aws-c-common/80f21b3cac5ac51c6b8a62c7d2a5ef58a75195ee"; flake = false; };
     contrib-aws-checksums = { url = "github:awslabs/aws-checksums/321b805559c8e911be5bddba13fcbd222a3e2d3a"; flake = false; };
-    contrib-curl = { url = "github:curl/curl/4dacb79fcdd9364c1083e06f6a011d797a344f47"; flake = false; };
+    contrib-curl = { url = "github:curl/curl/cfbfb65047e85e6b08af65fe9cdbcf68e9ad496a"; flake = false; };
     contrib-icudata = { url = "github:ClickHouse/icudata/cfc05b4c3140ff2be84291b80de8c62b1e42d0da"; flake = false; };
     contrib-icu = { url = "github:ClickHouse/icu/4216173eeeb39c1d4caaa54a68860e800412d273"; flake = false; };
     contrib-flatbuffers = { url = "github:ClickHouse/flatbuffers/0100f6a5779831fa7a651e4b67ef389a8752bd9b"; flake = false; };
diff --git a/programs/server/dashboard.html b/programs/server/dashboard.html
@@ -3,7 +3,7 @@
 <head>
     <meta charset="UTF-8">
     <title>ClickHouse Dashboard</title>
-    <link rel="icon" href="data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHdpZHRoPSI1NCIgaGVpZ2h0PSI0OCIgdmlld0JveD0iMCAwIDkgOCI+PHN0eWxlPi5ve2ZpbGw6I2ZjMH0ucntmaWxsOnJlZH08L3N0eWxlPjxwYXRoIGQ9Ik0wLDcgaDEgdjEgaC0xIHoiIGNsYXNzPSJyIi8+PHBhdGggZD0iTTAsMCBoMSB2NyBoLTEgeiIgY2xhc3M9Im8iLz48cGF0aCBkPSJNMiwwIGgxIHY4IGgtMSB6IiBjbGFzcz0ibyIvPjxwYXRoIGQ9Ik00LDAgaDEgdjggaC0xIHoiIGNsYXNzPSJvIi8+PHBhdGggZD0iTTYsMCBoMSB2OCBoLTEgeiIgY2xhc3M9Im8iLz48cGF0aCBkPSJNOCwzLjI1IGgxIHYxLjUgaC0xIHoiIGNsYXNzPSJvIi8+PC9zdmc+">
+    <link rel="icon" href="data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHdpZHRoPSI1NCIgaGVpZ2h0PSI0OCIgdmlld0JveD0iMCAwIDExIDEwIj48c3R5bGU+LmJne2ZpbGw6IzAwMH0ub3tmaWxsOiNmZjB9PC9zdHlsZT48cmVjdCBjbGFzcz0iYmciIHg9IjAiIHk9IjAiIHdpZHRoPSIxMDAlIiBoZWlnaHQ9IjEwMCUiLz48cGF0aCBkPSJNMSwxIGgxIHY4IGgtMSB6IiBjbGFzcz0ibyIvPjxwYXRoIGQ9Ik0zLDEgaDEgdjggaC0xIHoiIGNsYXNzPSJvIi8+PHBhdGggZD0iTTUsMSBoMSB2OCBoLTEgeiIgY2xhc3M9Im8iLz48cGF0aCBkPSJNNywxIGgxIHY4IGgtMSB6IiBjbGFzcz0ibyIvPjxwYXRoIGQ9Ik05LDQuMjUgaDEgdjEuNSBoLTEgeiIgY2xhc3M9Im8iLz48L3N2Zz4">
     <script src="https://cdn.jsdelivr.net/npm/uplot@1.6.21/dist/uPlot.iife.min.js"></script>
     <script src="https://cdn.jsdelivr.net/npm/lz-string@1.5.0/libs/lz-string.min.js"></script>
     <style>
diff --git a/programs/server/play.html b/programs/server/play.html
@@ -707,6 +707,15 @@
             color: var(--misc-text-color);
         }
 
+        /* Prevents a different color when Chromium auto-fills inputs from the list. */
+        input:-webkit-autofill,
+        input:-webkit-autofill:hover,
+        input:-webkit-autofill:focus,
+        input:-webkit-autofill:active
+        {
+            transition: background-color 600000s 0s, color 600000s 0s;
+        }
+
         /* This is for charts (uPlot), Copyright (c) 2022 Leon Sorokin, MIT License, https://github.com/leeoniya/uPlot/ */
         .u-wrap {position: relative;user-select: none;}
         .u-over, .u-under, .u-axis {position: absolute;}
@@ -749,21 +758,21 @@
         </div>
     </div>
     <div id="main">
-        <div id="controls">
+        <form id="controls">
             <div id="inputs">
-                <input spellcheck="false" class="monospace shadow" id="url" type="text" value="http://localhost:8123/" placeholder="url" /><span id="url_status"><span id="server_info"></span>●</span><input spellcheck="false" class="monospace shadow" id="user" type="text" value="default" placeholder="user" /><input class="monospace shadow" id="password" type="password" placeholder="password" />
+                <input name="url" spellcheck="false" class="monospace shadow" id="url" type="url" value="" placeholder="url" /><span id="url_status"><span id="server_info"></span>●</span><input name="user" spellcheck="false" class="monospace shadow" id="user" type="text" value="default" placeholder="user" /><input name="password" class="monospace shadow" id="password" type="password" placeholder="password" />
             </div>
             <div id="query_div"><textarea autofocus spellcheck="false" autocorrect="false" autocomplete="false" data-gramm="false" class="monospace shadow" id="query"></textarea></div>
             <div id="run_div">
-                <button class="shadow" id="run">Run</button>
+                <button type="submit" class="shadow" id="run">Run</button>
                 <div id="hint">&nbsp;(Ctrl/Cmd+Enter)</div>
                 <div id="hourglass">⧗</div>
                 <div id="check-mark">✔</div>
                 <div id="progress"></div>
                 <div id="stats"></div>
                 <div id="theme"><span id="toggle-dark">🌘</span><span id="toggle-light">☀️</span></div>
             </div>
-        </div>
+        </form>
         <div id="data_div">
             <table class="monospace shadow" id="data-table"></table>
             <pre class="monospace shadow" id="data-unparsed"></pre>
@@ -804,12 +813,16 @@
 let user_elem = document.getElementById('user');
 let password_elem = document.getElementById('password');
 
-const server_address = current_url.searchParams.get('url');
-if (server_address) {
-    url_elem.value = server_address;
-} else if (!opened_locally) {
-    /// Substitute the address of the server where the page is served.
-    url_elem.value = location.origin;
+if (url_elem.value == '') {
+    const server_address = current_url.searchParams.get('url');
+    if (server_address) {
+        url_elem.value = server_address;
+    } else if (!opened_locally) {
+        /// Substitute the address of the server where the page is served.
+        url_elem.value = location.origin;
+    } else {
+        url_elem.value = 'http://localhost:8123/';
+    }
 }
 
 /// Substitute username if it's specified in the query string
@@ -1364,19 +1377,27 @@
     document.getElementById('run').innerText = 'Run';
 }
 
-document.getElementById('run').onclick = function(e)
+document.getElementById('controls').addEventListener('submit', e =>
 {
+    e.preventDefault();
     if (in_flight) {
         cancel();
     } else {
         post();
+
+        const cred = new PasswordCredential({
+            id: user_elem.value,
+            password: password_elem.value,
+            name: url_elem.value,
+        });
+        navigator.credentials.store(cred);
     }
-}
+});
 
 document.addEventListener('keydown', event => {
     /// Firefox has code 13 for Enter and Chromium has code 10.
     if ((event.metaKey || event.ctrlKey) && (event.keyCode == 13 || event.keyCode == 10)) {
-        post();
+        document.getElementById('controls').requestSubmit();
     }
 });
 
diff --git a/src/Interpreters/HashJoin/ScatteredBlock.h b/src/Interpreters/HashJoin/ScatteredBlock.h
@@ -269,8 +269,14 @@ struct ScatteredBlock : private boost::noncopyable
         chassert(rows() == filter.size());
         IndexesPtr new_selector = Indexes::create();
         new_selector->reserve(selector.size());
-        std::copy_if(
-            selector.begin(), selector.end(), std::back_inserter(new_selector->getData()), [&](size_t idx) { return filter[idx]; });
+        auto & new_selector_data = new_selector->getData();
+        size_t i = 0;
+        for (auto it = selector.begin(); it != selector.end(); ++it, ++i)
+        {
+            chassert(i < filter.size());
+            if (filter[i])
+                new_selector_data.push_back(*it);
+        }
         selector = Selector(std::move(new_selector));
     }
 
diff --git a/src/Storages/ObjectStorageQueue/ObjectStorageQueueSettings.cpp b/src/Storages/ObjectStorageQueue/ObjectStorageQueueSettings.cpp
@@ -39,6 +39,8 @@ namespace ErrorCodes
     DECLARE(UInt32, cleanup_interval_max_ms, 60000, "For unordered mode. Polling backoff max for cleanup", 0) \
     DECLARE(UInt64, buckets, 0, "Number of buckets for Ordered mode parallel processing", 0) \
     DECLARE(UInt64, list_objects_batch_size, 1000, "Size of a list batch in object storage", 0) \
+    DECLARE(UInt64, min_insert_block_size_rows_for_materialized_views, 0, "Override for profile setting min_insert_block_size_rows_for_materialized_views", 0) \
+    DECLARE(UInt64, min_insert_block_size_bytes_for_materialized_views, 0, "Override for profile setting min_insert_block_size_bytes_for_materialized_views", 0) \
     DECLARE(Bool, enable_hash_ring_filtering, 0, "Enable filtering files among replicas according to hash ring for Unordered mode", 0) \
     DECLARE(UInt64, max_processed_files_before_commit, 100, "Number of files which can be processed before being committed to keeper (in case of parallel_inserts=true, works on a per-thread basis)", 0) \
     DECLARE(UInt64, max_processed_rows_before_commit, 0, "Number of rows which can be processed before being committed to keeper (in case of parallel_inserts=true, works on a per-thread basis)", 0) \
diff --git a/src/Storages/ObjectStorageQueue/StorageObjectStorageQueue.cpp b/src/Storages/ObjectStorageQueue/StorageObjectStorageQueue.cpp
@@ -96,6 +96,8 @@ namespace ObjectStorageQueueSetting
     extern const ObjectStorageQueueSettingsObjectStorageQueueAction after_processing;
     extern const ObjectStorageQueueSettingsUInt64 list_objects_batch_size;
     extern const ObjectStorageQueueSettingsBool enable_hash_ring_filtering;
+    extern const ObjectStorageQueueSettingsUInt64 min_insert_block_size_rows_for_materialized_views;
+    extern const ObjectStorageQueueSettingsUInt64 min_insert_block_size_bytes_for_materialized_views;
 }
 
 namespace ErrorCodes
@@ -189,6 +191,8 @@ StorageObjectStorageQueue::StorageObjectStorageQueue(
         .max_processed_bytes_before_commit = (*queue_settings_)[ObjectStorageQueueSetting::max_processed_bytes_before_commit],
         .max_processing_time_sec_before_commit = (*queue_settings_)[ObjectStorageQueueSetting::max_processing_time_sec_before_commit],
     })
+    , min_insert_block_size_rows_for_materialized_views((*queue_settings_)[ObjectStorageQueueSetting::min_insert_block_size_rows_for_materialized_views])
+    , min_insert_block_size_bytes_for_materialized_views((*queue_settings_)[ObjectStorageQueueSetting::min_insert_block_size_bytes_for_materialized_views])
     , configuration{configuration_}
     , format_settings(format_settings_)
     , reschedule_processing_interval_ms((*queue_settings_)[ObjectStorageQueueSetting::polling_min_timeout_ms])
@@ -603,6 +607,18 @@ bool StorageObjectStorageQueue::streamToViews(size_t streaming_tasks_index)
     auto queue_context = Context::createCopy(getContext());
     queue_context->makeQueryContext();
 
+    size_t min_insert_block_size_rows;
+    size_t min_insert_block_size_bytes;
+    {
+        std::lock_guard lock(mutex);
+        min_insert_block_size_rows = min_insert_block_size_rows_for_materialized_views;
+        min_insert_block_size_bytes = min_insert_block_size_bytes_for_materialized_views;
+    }
+    if (min_insert_block_size_rows)
+        queue_context->setSetting("min_insert_block_size_rows_for_materialized_views", min_insert_block_size_rows);
+    if (min_insert_block_size_bytes)
+        queue_context->setSetting("min_insert_block_size_bytes_for_materialized_views", min_insert_block_size_bytes);
+
     std::shared_ptr<StorageObjectStorageQueue::FileIterator> file_iterator;
     {
         std::lock_guard streaming_lock(streaming_mutex);
@@ -803,6 +819,8 @@ static const std::unordered_set<std::string_view> changeable_settings_unordered_
     "max_processing_time_sec_before_commit",
     "enable_hash_ring_filtering",
     "list_objects_batch_size",
+    "min_insert_block_size_rows_for_materialized_views",
+    "min_insert_block_size_bytes_for_materialized_views",
 };
 
 static const std::unordered_set<std::string_view> changeable_settings_ordered_mode
@@ -818,6 +836,8 @@ static const std::unordered_set<std::string_view> changeable_settings_ordered_mo
     "max_processing_time_sec_before_commit",
     "buckets",
     "list_objects_batch_size",
+    "min_insert_block_size_rows_for_materialized_views",
+    "min_insert_block_size_bytes_for_materialized_views",
 };
 
 static std::string normalizeSetting(const std::string & name)
@@ -1077,6 +1097,11 @@ void StorageObjectStorageQueue::alter(
             if (change.name == "max_processing_time_sec_before_commit")
                 commit_settings.max_processing_time_sec_before_commit = change.value.safeGet<UInt64>();
 
+            if (change.name == "min_insert_block_size_rows_for_materialized_views")
+                min_insert_block_size_rows_for_materialized_views = change.value.safeGet<UInt64>();
+            if (change.name == "min_insert_block_size_bytes_for_materialized_views")
+                min_insert_block_size_bytes_for_materialized_views = change.value.safeGet<UInt64>();
+
             if (change.name == "list_objects_batch_size")
                 list_objects_batch_size = change.value.safeGet<UInt64>();
             if (change.name == "enable_hash_ring_filtering")
@@ -1166,6 +1191,8 @@ ObjectStorageQueueSettings StorageObjectStorageQueue::getSettings() const
         settings[ObjectStorageQueueSetting::max_processing_time_sec_before_commit] = commit_settings.max_processing_time_sec_before_commit;
         settings[ObjectStorageQueueSetting::enable_hash_ring_filtering] = enable_hash_ring_filtering;
         settings[ObjectStorageQueueSetting::list_objects_batch_size] = list_objects_batch_size;
+        settings[ObjectStorageQueueSetting::min_insert_block_size_rows_for_materialized_views] = min_insert_block_size_rows_for_materialized_views;
+        settings[ObjectStorageQueueSetting::min_insert_block_size_bytes_for_materialized_views] = min_insert_block_size_bytes_for_materialized_views;
     }
 
     return settings;
diff --git a/src/Storages/ObjectStorageQueue/StorageObjectStorageQueue.h b/src/Storages/ObjectStorageQueue/StorageObjectStorageQueue.h
@@ -94,14 +94,15 @@ class StorageObjectStorageQueue : public IStorage, WithContext
     const std::string engine_name;
     const fs::path zk_path;
     const bool enable_logging_to_queue_log;
-
     mutable std::mutex mutex;
     UInt64 polling_min_timeout_ms TSA_GUARDED_BY(mutex);
     UInt64 polling_max_timeout_ms TSA_GUARDED_BY(mutex);
     UInt64 polling_backoff_ms TSA_GUARDED_BY(mutex);
     UInt64 list_objects_batch_size TSA_GUARDED_BY(mutex);
     bool enable_hash_ring_filtering TSA_GUARDED_BY(mutex);
     CommitSettings commit_settings TSA_GUARDED_BY(mutex);
+    size_t min_insert_block_size_rows_for_materialized_views TSA_GUARDED_BY(mutex);
+    size_t min_insert_block_size_bytes_for_materialized_views TSA_GUARDED_BY(mutex);
 
     std::unique_ptr<ObjectStorageQueueMetadata> temp_metadata;
     std::shared_ptr<ObjectStorageQueueMetadata> files_metadata;
diff --git a/tests/integration/test_storage_s3_queue/test_4.py b/tests/integration/test_storage_s3_queue/test_4.py
@@ -338,7 +338,9 @@ def get_count():
         max_processed_bytes_before_commit=666,
         max_processing_time_sec_before_commit=777,
         enable_hash_ring_filtering=false,
-        list_objects_batch_size=1234
+        list_objects_batch_size=1234,
+        min_insert_block_size_rows_for_materialized_views=123,
+        min_insert_block_size_bytes_for_materialized_views=321
     """
     )
 
@@ -356,6 +358,8 @@ def get_count():
         "max_processing_time_sec_before_commit": 777,
         "enable_hash_ring_filtering": "false",
         "list_objects_batch_size": 1234,
+        "min_insert_block_size_rows_for_materialized_views": 123,
+        "min_insert_block_size_bytes_for_materialized_views": 321,
     }
     string_settings = {"after_processing": "delete"}
 
diff --git a/tests/integration/test_storage_s3_queue/test_5.py b/tests/integration/test_storage_s3_queue/test_5.py
@@ -964,3 +964,74 @@ def check_in_text_log(message, logger_name):
     )
 
     node.query(f"DROP TABLE {new_table_name} SYNC")
+
+
+@pytest.mark.parametrize("mode", ["unordered", "ordered"])
+@pytest.mark.parametrize("limit", [1, 9999999999])
+def test_mv_settings(started_cluster, mode, limit):
+    node = started_cluster.instances["instance"]
+    table_name = f"test_mv_settings_{generate_random_string()}"
+    dst_table_name = f"{table_name}_dst"
+    keeper_path = f"/clickhouse/test_{table_name}"
+    files_path = f"{table_name}_data"
+    if limit == 9999999999:
+        expected_parts_num = 1
+    else:
+        expected_parts_num = 5
+
+    format = "column1 String"
+    create_table(
+        started_cluster,
+        node,
+        table_name,
+        mode,
+        files_path,
+        format=format,
+        additional_settings={
+            "keeper_path": keeper_path,
+            "s3queue_processing_threads_num": 1,
+            "polling_max_timeout_ms": 0,
+            "polling_min_timeout_ms": 0,
+            "min_insert_block_size_rows_for_materialized_views": limit,
+            "min_insert_block_size_bytes_for_materialized_views": limit,
+        },
+    )
+
+    num_rows = 10
+
+    def insert():
+        files_to_generate = 5
+        table_name_suffix = f"{uuid.uuid4()}"
+        for i in range(files_to_generate):
+            file_name = f"file_{table_name}_{table_name_suffix}_{i}.csv"
+            s3_function = f"s3('http://{started_cluster.minio_host}:{started_cluster.minio_port}/{started_cluster.minio_bucket}/{files_path}/{file_name}', 'minio', '{minio_secret_key}')"
+            node.query(
+                f"INSERT INTO FUNCTION {s3_function} select randomString(10) FROM numbers({num_rows})"
+            )
+
+    insert()
+
+    mv_table_name = f"{table_name}_mv"
+    create_mv(
+        node,
+        table_name,
+        dst_table_name,
+        mv_name=mv_table_name,
+        format=format,
+    )
+    node.query(f"SYSTEM STOP MERGES {dst_table_name}")
+
+    def get_count():
+        return int(node.query(f"SELECT count() FROM {dst_table_name}"))
+
+    expected_rows = num_rows
+    for _ in range(20):
+        if expected_rows == get_count():
+            break
+        time.sleep(1)
+
+    assert expected_parts_num == int(
+        node.query(
+            f"SELECT count() FROM system.parts WHERE table = '{dst_table_name}' AND level = 0"
+        )
+    )
diff --git a/tests/queries/0_stateless/00160_merge_and_index_in_in.sql b/tests/queries/0_stateless/00160_merge_and_index_in_in.sql
diff --git a/tests/queries/0_stateless/00328_long_case_construction.sql b/tests/queries/0_stateless/00328_long_case_construction.sql
diff --git a/tests/queries/0_stateless/01825_new_type_json_ghdata_insert_select.sh b/tests/queries/0_stateless/01825_new_type_json_ghdata_insert_select.sh
diff --git a/tests/queries/0_stateless/03573_concurrent_hash_scatter_bug.reference b/tests/queries/0_stateless/03573_concurrent_hash_scatter_bug.reference
diff --git a/tests/queries/0_stateless/03573_concurrent_hash_scatter_bug.sql b/tests/queries/0_stateless/03573_concurrent_hash_scatter_bug.sql
