Antalya 26.1: bump to 26.1.6

ci/jobs/scripts/check_style/experimental_settings_ignore.txt

@@ -62,6 +62,7 @@ allow_experimental_dynamic_type
 allow_experimental_json_type
 allow_experimental_vector_similarity_index
 enable_vector_similarity_index
+allow_nullable_tuple_in_extracted_subcolumns
 allow_experimental_live_view
 allow_special_serialization_kinds_in_output_formats
 allow_not_comparable_types_in_comparison_functions

ci/jobs/scripts/workflow_hooks/filter_job.py

@@ -58,6 +58,15 @@ def should_skip_job(job_name):
         _info_cache = Info()
         print(f"INFO: PR labels: {_info_cache.pr_labels}")
 
+    # There is no way to prevent GitHub Actions from running the PR workflow on
+    # release branches, so we skip all jobs here. The ReleaseCI workflow is used
+    # for testing on release branches instead.
+    if (
+        Labels.RELEASE in _info_cache.pr_labels
+        or Labels.RELEASE_LTS in _info_cache.pr_labels
+    ):
+        return True, "Skipped for release PR"
+
     changed_files = _info_cache.get_kv_data("changed_files")
     if not changed_files:
         print("WARNING: no changed files found for PR - do not filter jobs")

cmake/autogenerated_versions.txt

@@ -2,13 +2,13 @@
 
 # NOTE: VERSION_REVISION has nothing common with DBMS_TCP_PROTOCOL_VERSION,
 # only DBMS_TCP_PROTOCOL_VERSION should be incremented on protocol changes.
-SET(VERSION_REVISION 54509)
+SET(VERSION_REVISION 54511)
 SET(VERSION_MAJOR 26)
 SET(VERSION_MINOR 1)
-SET(VERSION_PATCH 4)
-SET(VERSION_GITHASH 5549f2acae95c6d627654f50e212a85d059a55f9)
-SET(VERSION_DESCRIBE v26.1.4.20001.altinityantalya)
-SET(VERSION_STRING 26.1.4.20001.altinityantalya)
+SET(VERSION_PATCH 6)
+SET(VERSION_GITHASH d1072851f03c9dcae0bf59f48f5ec9b00405675d)
+SET(VERSION_DESCRIBE v26.1.6.20001.altinityantalya)
+SET(VERSION_STRING 26.1.6.20001.altinityantalya)
 # end of autochange
 
 SET(VERSION_TWEAK 20001)

contrib/mongo-c-driver-cmake/CMakeLists.txt

@@ -5,13 +5,13 @@ if(NOT USE_MONGODB)
 endif()
 
 set(libbson_VERSION_MAJOR 2)
-set(libbson_VERSION_MINOR 1)
+set(libbson_VERSION_MINOR 2)
 set(libbson_VERSION_PATCH 2)
-set(libbson_VERSION 2.1.2)
+set(libbson_VERSION 2.2.2)
 set(libmongoc_VERSION_MAJOR 2)
-set(libmongoc_VERSION_MINOR 1)
+set(libmongoc_VERSION_MINOR 2)
 set(libmongoc_VERSION_PATCH 2)
-set(libmongoc_VERSION 2.1.2)
+set(libmongoc_VERSION 2.2.2)
 
 set(LIBBSON_SOURCES_ROOT "${ClickHouse_SOURCE_DIR}/contrib/mongo-c-driver/src")
 set(LIBBSON_SOURCE_DIR "${LIBBSON_SOURCES_ROOT}/libbson/src")
@@ -136,6 +136,8 @@ set(UTF8PROC_SOURCE_DIR "${LIBBSON_SOURCES_ROOT}/utf8proc-2.8.0")
 set(UTF8PROC_SOURCES "${UTF8PROC_SOURCE_DIR}/utf8proc.c")
 set(UTHASH_SOURCE_DIR "${LIBBSON_SOURCES_ROOT}/uthash")
 
+set(MONGOC_CXX_COMPILER_ID "${CMAKE_CXX_COMPILER_ID}")
+set(MONGOC_CXX_COMPILER_VERSION "${CMAKE_CXX_COMPILER_VERSION}")
 configure_file(
         ${LIBMONGOC_SOURCE_DIR}/mongoc/mongoc-config.h.in
         ${LIBMONGOC_BINARY_DIR}/mongoc/mongoc-config.h
@@ -144,6 +146,10 @@ configure_file(
         ${LIBMONGOC_SOURCE_DIR}/mongoc/mongoc-version.h.in
         ${LIBMONGOC_BINARY_DIR}/mongoc/mongoc-version.h
 )
+configure_file(
+        ${LIBMONGOC_SOURCE_DIR}/mongoc/mongoc-config-private.h.in
+        ${LIBMONGOC_BINARY_DIR}/mongoc/mongoc-config-private.h
+)
 add_library(_libmongoc ${LIBMONGOC_SOURCES} ${COMMON_SOURCES} ${UTF8PROC_SOURCES})
 add_library(ch_contrib::libmongoc ALIAS _libmongoc)
 target_include_directories(_libmongoc SYSTEM PUBLIC ${LIBMONGOC_SOURCE_DIR} ${LIBMONGOC_BINARY_DIR} ${LIBMONGOC_SOURCE_DIR}/mongoc ${LIBMONGOC_BINARY_DIR}/mongoc ${COMMON_SOURCE_DIR} ${UTF8PROC_SOURCE_DIR} ${UTHASH_SOURCE_DIR} )

contrib/mongo-cxx-driver-cmake/CMakeLists.txt

@@ -12,12 +12,19 @@ include(GenerateExportHeader)
 
 set(BSONCXX_SOURCES
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/private/itoa.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/private/version.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v1/config/config.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v1/config/export.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v1/config/version.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v1/detail/postlude.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v1/detail/prelude.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/array/element.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/array/value.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/array/view.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/builder/core.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/config/config.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/config/export.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/config/version.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/decimal128.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/document/element.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/document/value.cpp
@@ -31,6 +38,7 @@ set(BSONCXX_SOURCES
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/types/bson_value/value.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/types/bson_value/view.cpp
         ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/validate.cpp
+        ${BSONCXX_SOURCES_DIR}/lib/bsoncxx/v_noabi/bsoncxx/vector.cpp
 )
 
 set(BSONCXX_POLY_USE_IMPLS ON)
@@ -95,6 +103,9 @@ set(MONGOCXX_SOURCES
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/private/conversions.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/private/mongoc.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/private/numeric_casting.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v1/config/config.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v1/config/export.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v1/config/version.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v1/detail/postlude.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v1/detail/prelude.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/bulk_write.cpp
@@ -103,6 +114,9 @@ set(MONGOCXX_SOURCES
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/client_encryption.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/client_session.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/collection.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/config/config.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/config/export.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/config/version.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/cursor.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/database.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/events/command_failed_event.cpp
@@ -119,6 +133,7 @@ set(MONGOCXX_SOURCES
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/events/topology_closed_event.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/events/topology_description.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/events/topology_opening_event.cpp
+        ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/exception/authentication_exception.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/exception/bulk_write_exception.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/exception/error_code.cpp
         ${MONGOCXX_SOURCES_DIR}/lib/mongocxx/v_noabi/mongocxx/exception/exception.cpp

contrib/postgres-cmake/pg_config.h

@@ -593,7 +593,7 @@
 #define PACKAGE_NAME "PostgreSQL"
 
 /* Define to the full name and version of this package. */
-#define PACKAGE_STRING "PostgreSQL 18.0"
+#define PACKAGE_STRING "PostgreSQL 18.3"
 
 /* Define to the one symbol short name of this package. */
 #define PACKAGE_TARNAME "postgresql"
@@ -602,7 +602,7 @@
 #define PACKAGE_URL "https://www.postgresql.org/"
 
 /* Define to the version of this package. */
-#define PACKAGE_VERSION "18.0"
+#define PACKAGE_VERSION "18.3"
 
 /* Define to the name of a signed 128-bit integer type. */
 #define PG_INT128_TYPE __int128
@@ -618,19 +618,19 @@
 #define PG_MAJORVERSION_NUM 18
 
 /* PostgreSQL minor version number */
-#define PG_MINORVERSION_NUM 0
+#define PG_MINORVERSION_NUM 3
 
 /* Define to best printf format archetype, usually gnu_printf if available. */
 #define PG_PRINTF_ATTRIBUTE gnu_printf
 
 /* PostgreSQL version as a string */
-#define PG_VERSION "18.0"
+#define PG_VERSION "18.3"
 
 /* PostgreSQL version as a number */
-#define PG_VERSION_NUM 180000
+#define PG_VERSION_NUM 180003
 
 /* A string containing the version number, platform, and C compiler */
-#define PG_VERSION_STR "PostgreSQL 18.0 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 15.2.1 20250813, 64-bit"
+#define PG_VERSION_STR "PostgreSQL 18.3 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 15.2.1 20250813, 64-bit"
 
 /* Define to 1 to allow profiling output to be saved separately for each
    process. */

docs/en/sql-reference/functions/udf.md

@@ -44,6 +44,8 @@ A function configuration contains the following settings:
 | `execute_direct`              | If `execute_direct` = `1`, then `command` will be searched inside user_scripts folder specified by [user_scripts_path](../../operations/server-configuration-parameters/settings.md#user_scripts_path). Additional script arguments can be specified using whitespace separator. Example: `script_name arg1 arg2`. If `execute_direct` = `0`, `command` is passed as argument for `bin/sh -c` | Optional  | `1`                   |
 | `lifetime`                    | The reload interval of a function in seconds. If it is set to `0` then the function is not reloaded                                                                                                                                                                                                                                                                                           | Optional  | `0`                   |
 | `deterministic`               | If the function is deterministic (returns the same result for the same input)                                                                                                                                                                                                                                                                                                                 | Optional  | `false`               |
+| `stderr_reaction`             | How to handle the command's stderr output. Values: `none` (ignore), `log` (log all stderr immediately), `log_first` (log first 4 KiB after exit), `log_last` (log last 4 KiB after exit), `throw` (throw exception immediately on any stderr output). When using `log_first` or `log_last` with a non-zero exit code, the stderr content is included in the exception message              | Optional  | `log_last`            |
+| `check_exit_code`             | If true, ClickHouse will check the exit code of the command. A non-zero exit code causes an exception                                                                                                                                                                                                                                                                                         | Optional  | `true`                |
 
 The command must read arguments from `STDIN` and must output the result to `STDOUT`. The command must process arguments iteratively. That is after processing a chunk of arguments it must wait for the next chunk.
 

src/AggregateFunctions/AggregateFunctionGroupNumericIndexedVectorDataBSI.h

@@ -463,6 +463,19 @@ class BSINumericIndexedVector
      */
     void pointwiseAddInplace(const BSINumericIndexedVector & rhs)
     {
+        /// Self-addition requires a deep copy because the full adder logic below
+        /// performs in-place XOR on shared bitmaps (`sum->rb_xor(*addend)` where
+        /// `sum` and `addend` alias the same Roaring bitmap via `shallowCopyFrom`),
+        /// which triggers an assertion in CRoaring (`assert(x1 != x2)`) and would
+        /// produce incorrect results (A XOR A = 0) in release builds.
+        if (this == &rhs)
+        {
+            BSINumericIndexedVector copy;
+            copy.deepCopyFrom(rhs);
+            pointwiseAddInplace(copy);
+            return;
+        }
+
         if (isEmpty())
         {
             deepCopyFrom(rhs);
@@ -539,6 +552,16 @@ class BSINumericIndexedVector
      */
     void pointwiseSubtractInplace(const BSINumericIndexedVector & rhs)
     {
+        /// Self-subtraction requires a deep copy for the same reason as
+        /// `pointwiseAddInplace`: in-place XOR on aliased bitmaps is undefined.
+        if (this == &rhs)
+        {
+            BSINumericIndexedVector copy;
+            copy.deepCopyFrom(rhs);
+            pointwiseSubtractInplace(copy);
+            return;
+        }
+
         auto total_indexes = getAllIndex();
         total_indexes->rb_or(*rhs.getAllIndex());
 

src/AggregateFunctions/AggregateFunctionSumCount.cpp

@@ -1,6 +1,7 @@
 #include <AggregateFunctions/AggregateFunctionFactory.h>
 #include <AggregateFunctions/Helpers.h>
 #include <AggregateFunctions/FactoryHelpers.h>
+#include <AggregateFunctions/Combinators/AggregateFunctionNull.h>
 #include <DataTypes/DataTypeTuple.h>
 #include <AggregateFunctions/AggregateFunctionAvg.h>
 
@@ -45,6 +46,25 @@ class AggregateFunctionSumCount final : public AggregateFunctionAvg<T>
 
     String getName() const final { return "sumCount"; }
 
+    /// Keep the legacy nullable behavior/state layout for sumCount.
+    /// After `Nullable(Tuple)` was introduced, for Nullable arguments in the
+    /// generic Null-combinator path it started using `AggregateFunctionNullUnary<true, true>`
+    /// instead of `AggregateFunctionNullUnary<false, false>` for sumCount.
+    /// This adds a leading null-flag byte during serialization and expects that
+    /// byte during deserialization, which breaks compatibility with previously
+    /// serialized sumCount states.
+    /// So we force the legacy adapter for sumCount to preserve compatibility.
+    /// The extra null-flag is also redundant for sumCount: "has non-NULL rows"
+    /// can be inferred from `count` (`count > 0` means at least one row was seen).
+    AggregateFunctionPtr getOwnNullAdapter(
+        const AggregateFunctionPtr & nested_function,
+        const DataTypes & arguments,
+        const Array & params,
+        const AggregateFunctionProperties & /*properties*/) const final
+    {
+        return std::make_shared<AggregateFunctionNullUnary<false, false>>(nested_function, arguments, params);
+    }
+
 #if USE_EMBEDDED_COMPILER
 
     bool isCompilable() const override

src/Analyzer/Passes/FunctionToSubcolumnsPass.cpp

@@ -436,7 +436,7 @@ std::tuple<FunctionNode *, ColumnNode *, TableNode *> getTypedNodesForOptimizati
         return {};
 
     auto * first_argument_column_node = function_arguments_nodes.front()->as<ColumnNode>();
-    if (!first_argument_column_node || first_argument_column_node->getColumnName() == "__grouping_set")
+    if (!first_argument_column_node || first_argument_column_node->getColumnName() == "__grouping_set" || first_argument_column_node->hasExpression())
         return {};
 
     auto column_source = first_argument_column_node->getColumnSource();

src/Analyzer/Passes/InverseDictionaryLookupPass.cpp

@@ -142,12 +142,6 @@ class InverseDictionaryLookupVisitor : public InDepthQueryTreeVisitorWithContext
         if (getSettings()[Setting::rewrite_in_to_join])
             return;
 
-        /// This rewrite turns `dictGet(...)` predicates into `IN (SELECT ... FROM dictionary(...))`.
-        /// The `dictionary()` table function requires `CREATE TEMPORARY TABLE`; if that grant is missing,
-        /// skip the optimization to avoid `ACCESS_DENIED`.
-        if (!getContext()->getAccess()->isGranted(AccessType::CREATE_TEMPORARY_TABLE))
-            return;
-
         auto * node_function = node->as<FunctionNode>();
 
         if (!node_function)
@@ -301,6 +295,12 @@ class InverseDictionaryLookupVisitor : public InDepthQueryTreeVisitorWithContext
 
 void InverseDictionaryLookupPass::run(QueryTreeNodePtr & query_tree_node, ContextPtr context)
 {
+    /// This rewrite turns `dictGet(...)` predicates into `IN (SELECT ... FROM dictionary(...))`.
+    /// The `dictionary()` table function requires `CREATE TEMPORARY TABLE`; if that grant is missing,
+    /// skip the optimization to avoid `ACCESS_DENIED`.
+    if (!context->getAccess()->isGranted(AccessType::CREATE_TEMPORARY_TABLE))
+        return;
+
     InverseDictionaryLookupVisitor visitor(std::move(context));
     visitor.visit(query_tree_node);
 }