Skip to content

Commit 2d1baaf

Browse files
committed
Made iceberg_read_optimization_enabled const
1 parent 787a51e commit 2d1baaf

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

src/Interpreters/ClusterFunctionReadTask.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ namespace Setting
2323
}
2424

2525
ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr object, const ContextPtr & context)
26+
: iceberg_read_optimization_enabled(context->getSettingsRef()[Setting::allow_experimental_iceberg_read_optimization])
2627
{
2728
if (!object)
2829
throw Exception(ErrorCodes::LOGICAL_ERROR, "`object` cannot be null");
@@ -32,8 +33,6 @@ ClusterFunctionReadTaskResponse::ClusterFunctionReadTaskResponse(ObjectInfoPtr o
3233

3334
file_meta_info = object->file_meta_info;
3435

35-
iceberg_read_optimization_enabled = context->getSettingsRef()[Setting::allow_experimental_iceberg_read_optimization];
36-
3736
const bool send_over_whole_archive = !context->getSettingsRef()[Setting::cluster_function_process_archive_on_multiple_nodes];
3837
path = send_over_whole_archive ? object->getPathOrPathToArchiveIfArchive() : object->getPath();
3938
}

src/Interpreters/ClusterFunctionReadTask.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ struct ClusterFunctionReadTaskResponse
2323
/// File's columns info
2424
std::optional<DataFileMetaInfoPtr> file_meta_info;
2525

26-
bool iceberg_read_optimization_enabled;
26+
const bool iceberg_read_optimization_enabled = false;
2727

2828
/// Convert received response into ObjectInfo.
2929
ObjectInfoPtr getObjectInfo() const;

0 commit comments

Comments
 (0)