Altinity · strtgbb · Apr 22, 2026 · Apr 22, 2026 · May 2, 2026 · May 4, 2026
diff --git a/ci/defs/job_configs.py b/ci/defs/job_configs.py
@@ -149,7 +149,7 @@
             "./ci/jobs/scripts/docker_in_docker.sh",
         ],
     ),
-    run_in_docker=f"altinityinfra/integration-tests-runner+root+--memory={LIMITED_MEM}+--privileged+--dns-search='.'+--security-opt seccomp=unconfined+--cap-add=SYS_PTRACE+{docker_sock_mount}+--volume=clickhouse_integration_tests_volume:/var/lib/docker+--cgroupns=host+--env=CLICKHOUSE_TEST_STAT_URL=$CLICKHOUSE_TEST_STAT_URL+--env=CLICKHOUSE_TEST_STAT_LOGIN=$CLICKHOUSE_TEST_STAT_LOGIN+--env=CLICKHOUSE_TEST_STAT_PASSWORD=$CLICKHOUSE_TEST_STAT_PASSWORD",
+    run_in_docker=f"altinityinfra/integration-tests-runner+root+--memory={LIMITED_MEM}+--privileged+--dns-search='.'+--security-opt seccomp=unconfined+--cap-add=SYS_PTRACE+{docker_sock_mount}+--volume=clickhouse_integration_tests_volume:/var/lib/docker+--cgroupns=host+--ulimit nofile=262144:262144+--env=CLICKHOUSE_TEST_STAT_URL=$CLICKHOUSE_TEST_STAT_URL+--env=CLICKHOUSE_TEST_STAT_LOGIN=$CLICKHOUSE_TEST_STAT_LOGIN+--env=CLICKHOUSE_TEST_STAT_PASSWORD=$CLICKHOUSE_TEST_STAT_PASSWORD",
 )
 
 

diff --git a/ci/jobs/check_style.py b/ci/jobs/check_style.py
@@ -6,6 +6,7 @@
 from concurrent.futures import ProcessPoolExecutor
 from pathlib import Path
 
+from praktika.info import Info
 from praktika.result import Result
 from praktika.utils import Shell, Utils
 
@@ -573,7 +574,13 @@ def parse_args():
             )
         )
     testname = "test_numbers_check"
-    if testpattern.lower() in testname.lower():
+    # Skip on release branches and backport PRs: backports cherry-pick a small
+    # subset of test files, which legitimately leaves large gaps in the numbering.
+    info = Info()
+    release_branch_re = re.compile(r"^\d{2}\.\d+$")
+    branch_to_check = (info.base_branch or info.git_branch or "").removeprefix("release/")
+    is_release_branch = bool(release_branch_re.match(branch_to_check))
+    if testpattern.lower() in testname.lower() and not is_release_branch:
         results.append(
             Result.from_commands_run(
                 name=testname,

diff --git a/cmake/autogenerated_versions.txt b/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 54517)
+SET(VERSION_REVISION 54520)
 SET(VERSION_MAJOR 26)
 SET(VERSION_MINOR 3)
-SET(VERSION_PATCH 10)
-SET(VERSION_GITHASH 0d82c1998e3b4d54e110dd8a77a64d247c4bff4a)
-SET(VERSION_DESCRIBE v26.3.10.10001.altinitytest)
-SET(VERSION_STRING 26.3.10.10001.altinitytest)
+SET(VERSION_PATCH 13)
+SET(VERSION_GITHASH d23c7536b980c34b39c850b08ef23c509f06aaaa)
+SET(VERSION_DESCRIBE v26.3.13.10001.altinitytest)
+SET(VERSION_STRING 26.3.13.10001.altinitytest)
 # end of autochange
 
 SET(VERSION_TWEAK 20001)

diff --git a/contrib/avro b/contrib/avro
diff --git a/contrib/delta-kernel-rs b/contrib/delta-kernel-rs
diff --git a/contrib/mongo-c-driver b/contrib/mongo-c-driver
diff --git a/contrib/mongo-c-driver-cmake/CMakeLists.txt b/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 2)
-set(libbson_VERSION_PATCH 2)
-set(libbson_VERSION 2.2.2)
+set(libbson_VERSION_MINOR 3)
+set(libbson_VERSION_PATCH 0)
+set(libbson_VERSION 2.3.0)
 set(libmongoc_VERSION_MAJOR 2)
-set(libmongoc_VERSION_MINOR 2)
-set(libmongoc_VERSION_PATCH 2)
-set(libmongoc_VERSION 2.2.2)
+set(libmongoc_VERSION_MINOR 3)
+set(libmongoc_VERSION_PATCH 0)
+set(libmongoc_VERSION 2.3.0)
 
 set(LIBBSON_SOURCES_ROOT "${ClickHouse_SOURCE_DIR}/contrib/mongo-c-driver/src")
 set(LIBBSON_SOURCE_DIR "${LIBBSON_SOURCES_ROOT}/libbson/src")

diff --git a/contrib/replxx b/contrib/replxx
diff --git a/docs/en/sql-reference/statements/system.md b/docs/en/sql-reference/statements/system.md
@@ -724,7 +724,7 @@ SYSTEM STOP VIEWS
 
 Enable periodic refreshing for the given view or all refreshable views. No immediate refresh is triggered.
 
-If the view is in a Replicated or Shared database, `START VIEW` undoes the effect of `STOP VIEW`, and `START REPLICATED VIEW` undoes the effect of `STOP REPLICATED VIEW`.
+If the view is in a Replicated or Shared database, `START VIEW` undoes the effect of `STOP VIEW`, and `START REPLICATED VIEW` undoes the effect of `STOP REPLICATED VIEW`. `START VIEW` also undoes the effect of `PAUSE VIEW`.
 
 ```sql
 SYSTEM START VIEW [db.]name
@@ -733,7 +733,26 @@ SYSTEM START VIEW [db.]name
 SYSTEM START VIEWS
 ```
 
-### SYSTEM CANCEL VIEW {#cancel-view}
+### SYSTEM PAUSE VIEW, PAUSE VIEWS {#pause-view-pause-views}
+
+Disable periodic refreshing of the given view or all refreshable views.
+Unlike `SYSTEM STOP VIEW`, `SYSTEM PAUSE VIEW` does not interrupt a refresh that is already in progress: the running refresh is allowed to finish, and only subsequent refreshes are prevented.
+
+Undo with `SYSTEM START VIEW` or `SYSTEM START VIEWS`.
+
+:::note
+The paused state does not persist across server restarts. After a restart, views will resume their configured refresh schedules.
+In Replicated or Shared databases, `SYSTEM PAUSE VIEW` only affects the current replica.
+:::
+
+```sql
+SYSTEM PAUSE VIEW [db.]name
+```
+```sql
+SYSTEM PAUSE VIEWS
+```
+
+### SYSTEM REFRESH VIEW {#refresh-view}
 
 If there's a refresh in progress for the given view on the current replica, interrupt and cancel it. Otherwise do nothing.
 

diff --git a/src/Access/Common/AccessType.h b/src/Access/Common/AccessType.h
@@ -354,7 +354,7 @@ enum class AccessType : uint8_t
     M(SYSTEM_MOVES, "SYSTEM STOP MOVES, SYSTEM START MOVES, STOP MOVES, START MOVES", TABLE, SYSTEM) \
     M(SYSTEM_PULLING_REPLICATION_LOG, "SYSTEM STOP PULLING REPLICATION LOG, SYSTEM START PULLING REPLICATION LOG", TABLE, SYSTEM) \
     M(SYSTEM_CLEANUP, "SYSTEM STOP CLEANUP, SYSTEM START CLEANUP", TABLE, SYSTEM) \
-    M(SYSTEM_VIEWS, "SYSTEM REFRESH VIEW, SYSTEM START VIEWS, SYSTEM STOP VIEWS, SYSTEM START VIEW, SYSTEM STOP VIEW, SYSTEM CANCEL VIEW, REFRESH VIEW, START VIEWS, STOP VIEWS, START VIEW, STOP VIEW, CANCEL VIEW", VIEW, SYSTEM) \
+    M(SYSTEM_VIEWS, "SYSTEM REFRESH VIEW, SYSTEM START VIEWS, SYSTEM STOP VIEWS, SYSTEM START VIEW, SYSTEM STOP VIEW, SYSTEM PAUSE VIEWS, SYSTEM PAUSE VIEW, SYSTEM CANCEL VIEW, REFRESH VIEW, START VIEWS, STOP VIEWS, START VIEW, STOP VIEW, PAUSE VIEWS, PAUSE VIEW, CANCEL VIEW", VIEW, SYSTEM) \
     M(SYSTEM_DISTRIBUTED_SENDS, "SYSTEM STOP DISTRIBUTED SENDS, SYSTEM START DISTRIBUTED SENDS, STOP DISTRIBUTED SENDS, START DISTRIBUTED SENDS", TABLE, SYSTEM_SENDS) \
     M(SYSTEM_REPLICATED_SENDS, "SYSTEM STOP REPLICATED SENDS, SYSTEM START REPLICATED SENDS, STOP REPLICATED SENDS, START REPLICATED SENDS", TABLE, SYSTEM_SENDS) \
     M(SYSTEM_SENDS, "SYSTEM STOP SENDS, SYSTEM START SENDS, STOP SENDS, START SENDS", GROUP, SYSTEM) \

diff --git a/src/AggregateFunctions/AggregateFunctionSingleValueOrNull.cpp b/src/AggregateFunctions/AggregateFunctionSingleValueOrNull.cpp
@@ -92,7 +92,7 @@ struct AggregateFunctionSingleValueOrNullData
         {
             ColumnNullable & col = typeid_cast<ColumnNullable &>(to);
             col.getNullMapColumn().insertDefault();
-            data().insertResultInto(col.getNestedColumn(), result_type);
+            data().insertResultInto(col.getNestedColumn(), removeNullable(result_type));
         }
     }
 };
@@ -169,7 +169,7 @@ class AggregateFunctionSingleValueOrNull final
 
     void deserialize(AggregateDataPtr place, ReadBuffer & buf, std::optional<size_t> /* version */, Arena * arena) const override
     {
-        data(place).read(buf, *serialization, result_type, arena);
+        data(place).read(buf, *serialization, value_type, arena);
     }
 
     bool allocatesMemoryInArena() const override { return singleValueTypeAllocatesMemoryInArena(value_type->getTypeId()); }

diff --git a/src/AggregateFunctions/Combinators/AggregateFunctionOrFill.h b/src/AggregateFunctions/Combinators/AggregateFunctionOrFill.h
@@ -310,6 +310,42 @@ class AggregateFunctionOrFill final : public IAggregateFunctionHelper<AggregateF
                     nested_function->insertResultInto(place, to, arena);
             }
         }
+        else if (nested_function->isState())
+        {
+            /// Mirror the flag-set branch for State-nested combinators: routing
+            /// flag-unset rows through `to.insertDefault()` would call
+            /// `ColumnAggregateFunction::ensureOwnership()` on the inner column and
+            /// reset its `src`, leaving subsequent flag-set rows pushing externally-
+            /// owned state pointers without `src` protection (double-destroy under
+            /// `MemorySanitizer`, issue #105462). The state at `place` is already
+            /// default-initialized by `create()` above, so it is safe to forward.
+            if constexpr (UseNull)
+            {
+                if (!result_is_nullable || inner_nullable)
+                {
+                    if constexpr (merge)
+                        nested_function->insertMergeResultInto(place, to, arena);
+                    else
+                        nested_function->insertResultInto(place, to, arena);
+                }
+                else
+                {
+                    ColumnNullable & col = typeid_cast<ColumnNullable &>(to);
+                    col.getNullMapColumn().getData().push_back(static_cast<UInt8>(1));
+                    if constexpr (merge)
+                        nested_function->insertMergeResultInto(place, col.getNestedColumn(), arena);
+                    else
+                        nested_function->insertResultInto(place, col.getNestedColumn(), arena);
+                }
+            }
+            else
+            {
+                if constexpr (merge)
+                    nested_function->insertMergeResultInto(place, to, arena);
+                else
+                    nested_function->insertResultInto(place, to, arena);
+            }
+        }
         else
             to.insertDefault();
     }

diff --git a/src/AggregateFunctions/UniquesHashSet.h b/src/AggregateFunctions/UniquesHashSet.h
@@ -2,6 +2,7 @@
 
 #include <math.h>
 
+#include <base/defines.h>
 #include <base/types.h>
 
 #include <IO/WriteBuffer.h>
@@ -465,6 +466,9 @@ class UniquesHashSet : private HashTableAllocatorWithStackMemory<(1ULL << UNIQUE
         if (m_size > UNIQUES_HASH_MAX_SIZE)
             throw Poco::Exception("Cannot write UniquesHashSet: too large size_degree.");
 
+        /// A null `buf` here would indicate upstream state corruption (e.g. a double-destroyed state).
+        chassert(buf);
+
         DB::writeBinaryLittleEndian(skip_degree, wb);
         DB::writeVarUInt(m_size, wb);
 

diff --git a/src/Analyzer/FunctionNode.cpp b/src/Analyzer/FunctionNode.cpp
@@ -266,7 +266,8 @@ ASTPtr FunctionNode::toASTImpl(const ConvertToASTOptions & options) const
     /// tuple, and adding a type may significantly increase query size.
     /// It should be safe because set type for `column IN tuple` is deduced from `column` type.
     if (isNameOfInFunction(function_name) && argument_nodes.size() > 1 && argument_nodes[1]->getNodeType() == QueryTreeNodeType::CONSTANT
-        && !static_cast<const ConstantNode *>(argument_nodes[1].get())->hasSourceExpression())
+        && !static_cast<const ConstantNode *>(argument_nodes[1].get())->hasSourceExpression()
+        && !isArray(argument_nodes[1]->getResultType()))
     {
         auto expression_list_ast = make_intrusive<ASTExpressionList>();
-Original file line number
+Diff line change
@@ Expand Up / @@ -149,7 +149,7 @@ @@
                 "./ci/jobs/scripts/docker_in_docker.sh",
             ],
         ),
-        run_in_docker=f"altinityinfra/integration-tests-runner+root+--memory={LIMITED_MEM}+--privileged+--dns-search='.'+--security-opt seccomp=unconfined+--cap-add=SYS_PTRACE+{docker_sock_mount}+--volume=clickhouse_integration_tests_volume:/var/lib/docker+--cgroupns=host+--env=CLICKHOUSE_TEST_STAT_URL=$CLICKHOUSE_TEST_STAT_URL+--env=CLICKHOUSE_TEST_STAT_LOGIN=$CLICKHOUSE_TEST_STAT_LOGIN+--env=CLICKHOUSE_TEST_STAT_PASSWORD=$CLICKHOUSE_TEST_STAT_PASSWORD",
+        run_in_docker=f"altinityinfra/integration-tests-runner+root+--memory={LIMITED_MEM}+--privileged+--dns-search='.'+--security-opt seccomp=unconfined+--cap-add=SYS_PTRACE+{docker_sock_mount}+--volume=clickhouse_integration_tests_volume:/var/lib/docker+--cgroupns=host+--ulimit nofile=262144:262144+--env=CLICKHOUSE_TEST_STAT_URL=$CLICKHOUSE_TEST_STAT_URL+--env=CLICKHOUSE_TEST_STAT_LOGIN=$CLICKHOUSE_TEST_STAT_LOGIN+--env=CLICKHOUSE_TEST_STAT_PASSWORD=$CLICKHOUSE_TEST_STAT_PASSWORD",
     )
@@ Expand Down @@
+10 −5		lang/c++/api/Compiler.hh
+4 −2		lang/c++/api/DataFile.hh
+2 −1		lang/c++/api/LogicalType.hh
+19 −2		lang/c++/api/NodeImpl.hh
+2 −2		lang/c++/api/ValidSchema.hh
+48 −33		lang/c++/impl/Compiler.cc
+10 −7		lang/c++/impl/DataFile.cc
+3 −0		lang/c++/impl/LogicalType.cc
+8 −0		lang/c++/impl/NodeImpl.cc
+13 −8		lang/c++/impl/ValidSchema.cc
+17 −9		lang/c++/impl/json/JsonDom.cc
+4 −4		lang/c++/impl/json/JsonDom.hh
+2 −1		.github/workflows/ci.yml
+11 −2		examples/cxx-api.cxx
+1 −1		include/replxx.h
+5 −4		src/replxx.cxx
+7 −2		src/replxx_impl.cxx
+16 −10		src/terminal.cxx
+9 −0		src/util.cxx
+1,793 −1,632		tests.py