File tree Expand file tree Collapse file tree 2 files changed +2
-4
lines changed
Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -331,7 +331,6 @@ void IStorageCluster::updateQueryWithJoinToSendIfNeeded(
331331 /* allow_global_join_for_right_table*/ true ,
332332 /* find_cross_join*/ true );
333333 query_to_send = queryNodeToDistributedSelectQuery (modified_query_tree);
334- send_external_tables = true ;
335334 }
336335
337336 return ;
@@ -412,7 +411,7 @@ void IStorageCluster::read(
412411 auto this_ptr = std::static_pointer_cast<IStorageCluster>(shared_from_this ());
413412
414413 std::optional<Tables> external_tables = std::nullopt ;
415- if (send_external_tables && query_info.planner_context && query_info.planner_context ->getMutableQueryContext ())
414+ if (query_info.planner_context && query_info.planner_context ->getMutableQueryContext ())
416415 external_tables = query_info.planner_context ->getMutableQueryContext ()->getExternalTables ();
417416
418417 auto reading = std::make_unique<ReadFromCluster>(
@@ -615,7 +614,7 @@ QueryProcessingStage::Enum IStorageCluster::getQueryProcessingStage(
615614 {
616615 if (!context->getSettingsRef ()[Setting::allow_experimental_analyzer])
617616 throw Exception (ErrorCodes::NOT_IMPLEMENTED,
618- " object_storage_cluster_join_mode!='allow' is not supported without allow_experimental_analyzer=false " );
617+ " object_storage_cluster_join_mode!='allow' is not supported without allow_experimental_analyzer=true " );
619618
620619 if (object_storage_cluster_join_mode == ObjectStorageClusterJoinMode::LOCAL)
621620 {
Original file line number Diff line number Diff line change @@ -108,7 +108,6 @@ class IStorageCluster : public IStorage
108108
109109 LoggerPtr log;
110110 String cluster_name;
111- bool send_external_tables = false ;
112111
113112 struct QueryTreeInfo
114113 {
You can’t perform that action at this time.
0 commit comments