Skip to content

Swarm join in allowed mode failed with Not found column in block on 25.8.12.20678.altinityantalya #1244

New issue
New issue
Open
Open
Swarm join in allowed mode failed with Not found column in block on 25.8.12.20678.altinityantalya#1244
Assignees
ianton-ru
Labels
antalya
@alsugiliazova

Description

@alsugiliazova
alsugiliazova
opened on Dec 22, 2025

25.8.12.20678.altinityantalya

Describe the bug

SELECT *
FROM icebergS3Cluster(replicated_cluster, 'http://minio:9000/warehouse/data3') AS t1
LEFT OUTER JOIN database_fc782435_df89_11f0_84b0_e0c26496f172.\`namespace_027ed1f9_df8a_11f0_a1da_e0c26496f172.table_027ed2fc_df8a_11f0_8080_e0c26496f172\` AS t2
ON t1.integer_col = t2.integer_col 
ORDER BY tuple(*) 
SETTINGS object_storage_cluster_join_mode='allow', object_storage_cluster='replicated_cluster' FORMAT Values
Code: 10. DB::Exception: Received from localhost:9000. DB::Exception: Received from clickhouse1:9000. DB::Exception: Not found column __table2.boolean_col in block __table1.boolean_col Nullable(Bool) Nullable(size = 0, UInt8(size = 0), UInt8(size = 0)), __table1.long_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.double_col Nullable(Float64) Nullable(size = 0, Float64(size = 0), UInt8(size = 0)), __table1.string_col String String(size = 0), __table1.timestamp_col Nullable(DateTime64(6)) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.date_col Nullable(Date) Nullable(size = 0, UInt16(size = 0), UInt8(size = 0)), __table1.time_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.timestamptz_col Nullable(DateTime64(6, 'UTC')) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.integer_col Nullable(Int32) Nullable(size = 0, Int32(size = 0), UInt8(size = 0)), __table1.float_col Nullable(Float32) Nullable(size = 0, Float32(size = 0), UInt8(size = 0)), __table1.decimal_col Nullable(Decimal(10, 2)) Nullable(size = 0, Decimal64(size = 0), UInt8(size = 0)). (NOT_FOUND_COLUMN_IN_BLOCK)

Trace:

2025.12.23 00:02:18.523292 [ 2803 ] {d46a2a69-5926-4c1c-a23d-aa1660e657fa} <Error> executeQuery: Code: 10. DB::Exception: Not found column __table2.boolean_col in block __table1.boolean_col Nullable(Bool) Nullable(size = 0, UInt8(size = 0), UInt8(size = 0)), __table1.long_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.double_col Nullable(Float64) Nullable(size = 0, Float64(size = 0), UInt8(size = 0)), __table1.string_col String String(size = 0), __table1.timestamp_col Nullable(DateTime64(6)) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.date_col Nullable(Date) Nullable(size = 0, UInt16(size = 0), UInt8(size = 0)), __table1.time_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.timestamptz_col Nullable(DateTime64(6, 'UTC')) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.integer_col Nullable(Int32) Nullable(size = 0, Int32(size = 0), UInt8(size = 0)), __table1.float_col Nullable(Float32) Nullable(size = 0, Float32(size = 0), UInt8(size = 0)), __table1.decimal_col Nullable(Decimal(10, 2)) Nullable(size = 0, Decimal64(size = 0), UInt8(size = 0)). (NOT_FOUND_COLUMN_IN_BLOCK) (version 25.8.12.20678.altinityantalya) (from 172.19.0.9:39082) (query 1, line 2) (in query: SELECT __table1.boolean_col AS boolean_col, __table1.long_col AS long_col, __table1.double_col AS double_col, __table1.string_col AS string_col, __table1.timestamp_col AS timestamp_col, __table1.date_col AS date_col, __table1.time_col AS time_col, __table1.timestamptz_col AS timestamptz_col, __table1.integer_col AS integer_col, __table1.float_col AS float_col, __table1.decimal_col AS decimal_col, __table2.boolean_col AS `t2.boolean_col`, __table2.long_col AS `t2.long_col`, __table2.double_col AS `t2.double_col`, __table2.string_col AS `t2.string_col`, __table2.timestamp_col AS `t2.timestamp_col`, __table2.date_col AS `t2.date_col`, __table2.time_col AS `t2.time_col`, __table2.timestamptz_col AS `t2.timestamptz_col`, __table2.integer_col AS `t2.integer_col`, __table2.float_col AS `t2.float_col`, __table2.decimal_col AS `t2.decimal_col` FROM s3Cluster(replicated_cluster, 'http://minio:9000/warehouse/data1/data/**.parquet', 'admin', '[HIDDEN]', 'Parquet', '`boolean_col` Nullable(Bool), `long_col` Nullable(Int64), `double_col` Nullable(Float64), `string_col` Nullable(String), `timestamp_col` Nullable(DateTime64(6)), `date_col` Nullable(Date32), `time_col` Nullable(DateTime64(6)), `timestamptz_col` Nullable(DateTime64(6, \'UTC\')), `integer_col` Nullable(Int32), `float_col` Nullable(Float32), `decimal_col` Nullable(Decimal(10, 2))') AS __table1 ANY RIGHT JOIN database_fc782435_df89_11f0_84b0_e0c26496f172.`namespace_027ed1f9_df8a_11f0_a1da_e0c26496f172.table_027ed2fc_df8a_11f0_8080_e0c26496f172` AS __table2 ON __table1.timestamptz_col = __table2.timestamptz_col ORDER BY __table1.boolean_col ASC, __table1.long_col ASC, __table1.double_col ASC, __table1.string_col ASC, __table1.timestamp_col ASC, __table1.date_col ASC, __table1.time_col ASC, __table1.timestamptz_col ASC, __table1.integer_col ASC, __table1.float_col ASC, __table1.decimal_col ASC, __table2.boolean_col ASC, __table2.long_col ASC, __table2.double_col ASC, __table2.string_col ASC, __table2.timestamp_col ASC, __table2.date_col ASC, __table2.time_col ASC, __table2.timestamptz_col ASC, __table2.integer_col ASC, __table2.float_col ASC, __table2.decimal_col ASC SETTINGS object_storage_cluster_join_mode = 'allow', object_storage_cluster = 'replicated_cluster'), Stack trace (when copying this message, always include the lines below):

0. ./contrib/llvm-project/libcxx/include/__exception/exception.h:113: Poco::Exception::Exception(String const&, int) @ 0x000000001fa75cb2
1. ./ci/tmp/build/./src/Common/Exception.cpp:128: DB::Exception::Exception(DB::Exception::MessageMasked&&, int, bool) @ 0x000000000fca855e
2. DB::Exception::Exception(String&&, int, String, bool) @ 0x000000000924538e
3. DB::Exception::Exception(PreformattedMessage&&, int) @ 0x0000000009244f80
4. DB::Exception::Exception<String const&, String>(int, FormatStringHelperImpl<std::type_identity<String const&>::type, std::type_identity<String>::type>, String const&, String&&) @ 0x0000000009fdb4eb
5. ./ci/tmp/build/./src/Interpreters/ActionsDAG.cpp:1323: DB::ActionsDAG::appendInputsForUnusedColumns(DB::Block const&) @ 0x0000000015328e10
6. ./ci/tmp/build/./src/Planner/Planner.cpp:445: DB::(anonymous namespace)::addExpressionStep(std::shared_ptr<DB::PlannerContext> const&, DB::QueryPlan&, std::shared_ptr<DB::ActionsAndProjectInputsFlag>&, DB::CorrelatedSubtrees const&, DB::SelectQueryOptions const&, String const&, std::unordered_set<std::shared_ptr<DB::FutureSet>, std::hash<std::shared_ptr<DB::FutureSet>>, std::equal_to<std::shared_ptr<DB::FutureSet>>, std::allocator<std::shared_ptr<DB::FutureSet>>>&) @ 0x000000001563ef45
7. ./ci/tmp/build/./src/Planner/Planner.cpp:1765: DB::Planner::buildPlanForQueryNode() @ 0x0000000015637dd1
8. ./ci/tmp/build/./src/Planner/Planner.cpp:1425: DB::Planner::buildQueryPlanIfNeeded() @ 0x0000000015632cb3
9. ./ci/tmp/build/./src/Planner/PlannerJoinTree.cpp:1322: DB::(anonymous namespace)::buildQueryPlanForTableExpression(std::shared_ptr<DB::IQueryTreeNode>, std::shared_ptr<DB::IQueryTreeNode> const&, DB::SelectQueryInfo const&, DB::SelectQueryOptions const&, std::shared_ptr<DB::PlannerContext>&, bool, bool) @ 0x00000000156526ce
10. ./ci/tmp/build/./src/Planner/PlannerJoinTree.cpp:2530: DB::buildJoinTreeQueryPlan(std::shared_ptr<DB::IQueryTreeNode> const&, DB::SelectQueryInfo const&, DB::SelectQueryOptions&, std::unordered_set<String, std::hash<String>, std::equal_to<String>, std::allocator<String>> const&, std::shared_ptr<DB::PlannerContext>&) @ 0x000000001564ef65
11. ./ci/tmp/build/./src/Planner/Planner.cpp:1654: DB::Planner::buildPlanForQueryNode() @ 0x0000000015636092
12. ./ci/tmp/build/./src/Planner/Planner.cpp:1425: DB::Planner::buildQueryPlanIfNeeded() @ 0x0000000015632cb3
13. ./ci/tmp/build/./src/Interpreters/InterpreterSelectQueryAnalyzer.cpp:269: DB::InterpreterSelectQueryAnalyzer::getQueryPlan() @ 0x0000000015ee54cd
14. ./ci/tmp/build/./src/Interpreters/executeQuery.cpp:1523: DB::executeQueryImpl(char const*, char const*, std::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum, std::unique_ptr<DB::ReadBuffer, std::default_delete<DB::ReadBuffer>>&, std::shared_ptr<DB::IAST>&, std::shared_ptr<DB::ImplicitTransactionControlExecutor>) @ 0x00000000162146c3
15. ./ci/tmp/build/./src/Interpreters/executeQuery.cpp:1782: DB::executeQuery(String const&, std::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum) @ 0x00000000162103ee
16. ./ci/tmp/build/./src/Server/TCPHandler.cpp:739: DB::TCPHandler::runImpl() @ 0x0000000019a57826
17. ./ci/tmp/build/./src/Server/TCPHandler.cpp:2758: DB::TCPHandler::run() @ 0x0000000019a74416
18. ./ci/tmp/build/./base/poco/Net/src/TCPServerConnection.cpp:40: Poco::Net::TCPServerConnection::start() @ 0x000000001fb30e07
19. ./ci/tmp/build/./base/poco/Net/src/TCPServerDispatcher.cpp:115: Poco::Net::TCPServerDispatcher::run() @ 0x000000001fb313be
20. ./ci/tmp/build/./base/poco/Foundation/src/ThreadPool.cpp:205: Poco::PooledThread::run() @ 0x000000001fad05ff
21. ./base/poco/Foundation/src/Thread_POSIX.cpp:341: Poco::ThreadImpl::runnableEntry(void*) @ 0x000000001facdc0f
22. ? @ 0x0000000000094ac3
23. ? @ 0x0000000000126850

2025.12.23 00:02:18.525491 [ 2803 ] {} <Error> TCPHandler: Code: 10. DB::Exception: Not found column __table2.boolean_col in block __table1.boolean_col Nullable(Bool) Nullable(size = 0, UInt8(size = 0), UInt8(size = 0)), __table1.long_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.double_col Nullable(Float64) Nullable(size = 0, Float64(size = 0), UInt8(size = 0)), __table1.string_col String String(size = 0), __table1.timestamp_col Nullable(DateTime64(6)) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.date_col Nullable(Date) Nullable(size = 0, UInt16(size = 0), UInt8(size = 0)), __table1.time_col Nullable(Int64) Nullable(size = 0, Int64(size = 0), UInt8(size = 0)), __table1.timestamptz_col Nullable(DateTime64(6, 'UTC')) Nullable(size = 0, DateTime64(size = 0), UInt8(size = 0)), __table1.integer_col Nullable(Int32) Nullable(size = 0, Int32(size = 0), UInt8(size = 0)), __table1.float_col Nullable(Float32) Nullable(size = 0, Float32(size = 0), UInt8(size = 0)), __table1.decimal_col Nullable(Decimal(10, 2)) Nullable(size = 0, Decimal64(size = 0), UInt8(size = 0)). (NOT_FOUND_COLUMN_IN_BLOCK), Stack trace (when copying this message, always include the lines below):

0. ./contrib/llvm-project/libcxx/include/__exception/exception.h:113: Poco::Exception::Exception(String const&, int) @ 0x000000001fa75cb2
1. ./ci/tmp/build/./src/Common/Exception.cpp:128: DB::Exception::Exception(DB::Exception::MessageMasked&&, int, bool) @ 0x000000000fca855e
2. DB::Exception::Exception(String&&, int, String, bool) @ 0x000000000924538e
3. DB::Exception::Exception(PreformattedMessage&&, int) @ 0x0000000009244f80
4. DB::Exception::Exception<String const&, String>(int, FormatStringHelperImpl<std::type_identity<String const&>::type, std::type_identity<String>::type>, String const&, String&&) @ 0x0000000009fdb4eb
5. ./ci/tmp/build/./src/Interpreters/ActionsDAG.cpp:1323: DB::ActionsDAG::appendInputsForUnusedColumns(DB::Block const&) @ 0x0000000015328e10
6. ./ci/tmp/build/./src/Planner/Planner.cpp:445: DB::(anonymous namespace)::addExpressionStep(std::shared_ptr<DB::PlannerContext> const&, DB::QueryPlan&, std::shared_ptr<DB::ActionsAndProjectInputsFlag>&, DB::CorrelatedSubtrees const&, DB::SelectQueryOptions const&, String const&, std::unordered_set<std::shared_ptr<DB::FutureSet>, std::hash<std::shared_ptr<DB::FutureSet>>, std::equal_to<std::shared_ptr<DB::FutureSet>>, std::allocator<std::shared_ptr<DB::FutureSet>>>&) @ 0x000000001563ef45
7. ./ci/tmp/build/./src/Planner/Planner.cpp:1765: DB::Planner::buildPlanForQueryNode() @ 0x0000000015637dd1
8. ./ci/tmp/build/./src/Planner/Planner.cpp:1425: DB::Planner::buildQueryPlanIfNeeded() @ 0x0000000015632cb3
9. ./ci/tmp/build/./src/Planner/PlannerJoinTree.cpp:1322: DB::(anonymous namespace)::buildQueryPlanForTableExpression(std::shared_ptr<DB::IQueryTreeNode>, std::shared_ptr<DB::IQueryTreeNode> const&, DB::SelectQueryInfo const&, DB::SelectQueryOptions const&, std::shared_ptr<DB::PlannerContext>&, bool, bool) @ 0x00000000156526ce
10. ./ci/tmp/build/./src/Planner/PlannerJoinTree.cpp:2530: DB::buildJoinTreeQueryPlan(std::shared_ptr<DB::IQueryTreeNode> const&, DB::SelectQueryInfo const&, DB::SelectQueryOptions&, std::unordered_set<String, std::hash<String>, std::equal_to<String>, std::allocator<String>> const&, std::shared_ptr<DB::PlannerContext>&) @ 0x000000001564ef65
11. ./ci/tmp/build/./src/Planner/Planner.cpp:1654: DB::Planner::buildPlanForQueryNode() @ 0x0000000015636092
12. ./ci/tmp/build/./src/Planner/Planner.cpp:1425: DB::Planner::buildQueryPlanIfNeeded() @ 0x0000000015632cb3
13. ./ci/tmp/build/./src/Interpreters/InterpreterSelectQueryAnalyzer.cpp:269: DB::InterpreterSelectQueryAnalyzer::getQueryPlan() @ 0x0000000015ee54cd
14. ./ci/tmp/build/./src/Interpreters/executeQuery.cpp:1523: DB::executeQueryImpl(char const*, char const*, std::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum, std::unique_ptr<DB::ReadBuffer, std::default_delete<DB::ReadBuffer>>&, std::shared_ptr<DB::IAST>&, std::shared_ptr<DB::ImplicitTransactionControlExecutor>) @ 0x00000000162146c3
15. ./ci/tmp/build/./src/Interpreters/executeQuery.cpp:1782: DB::executeQuery(String const&, std::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum) @ 0x00000000162103ee
16. ./ci/tmp/build/./src/Server/TCPHandler.cpp:739: DB::TCPHandler::runImpl() @ 0x0000000019a57826
17. ./ci/tmp/build/./src/Server/TCPHandler.cpp:2758: DB::TCPHandler::run() @ 0x0000000019a74416
18. ./ci/tmp/build/./base/poco/Net/src/TCPServerConnection.cpp:40: Poco::Net::TCPServerConnection::start() @ 0x000000001fb30e07
19. ./ci/tmp/build/./base/poco/Net/src/TCPServerDispatcher.cpp:115: Poco::Net::TCPServerDispatcher::run() @ 0x000000001fb313be
20. ./ci/tmp/build/./base/poco/Foundation/src/ThreadPool.cpp:205: Poco::PooledThread::run() @ 0x000000001fad05ff
21. ./base/poco/Foundation/src/Thread_POSIX.cpp:341: Poco::ThreadImpl::runnableEntry(void*) @ 0x000000001facdc0f
22. ? @ 0x0000000000094ac3
23. ? @ 0x0000000000126850

Metadata

Metadata

Assignees

Labels

antalya

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions