mirror of https://github.com/ByConity/ByConity
Merge branch 'cherry-pick-commit-b6e281f1-1' into 'cnch-dev'
fix(clickhousech@m-3986737683): [cp] fix s3 input config parse See merge request dp/ClickHouse!25790
This commit is contained in:
parent
07ec6bd1ac
commit
d53cb3fb48
|
@ -145,6 +145,7 @@ void PartToolkitBase::applySettings()
|
|||
settings.set("s3_ak_id", s3_input_config->ak_id);
|
||||
settings.set("s3_ak_secret", s3_input_config->ak_secret);
|
||||
settings.set("s3_region", s3_input_config->region);
|
||||
settings.set("s3_use_virtual_hosted_style", s3_input_config->is_virtual_hosted_style);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -112,13 +112,6 @@ PartWriter::PartWriter(const ASTPtr & query_ptr_, ContextMutablePtr context_) :
|
|||
if (!endsWith(dest_path, "/"))
|
||||
dest_path.append("/");
|
||||
}
|
||||
|
||||
if (s3_input_config)
|
||||
{
|
||||
// Overwrite S3 source_path as:
|
||||
// `S3://<bucket>/<root_path>/<data_file>`
|
||||
source_path = "s3://" + s3_input_config->bucket + "/" + s3_input_config->root_prefix + "/" + source_path;
|
||||
}
|
||||
}
|
||||
|
||||
PartWriter::~PartWriter()
|
||||
|
|
Loading…
Reference in New Issue