RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-20 10:01:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #52651 from galsalomon66/trino_tpcds_qe_fixes

Browse Source 
rgw/s3select: s3select fixes related to Trino/TPCDS benchmark and QE tests

Reviewed-by: Casey Bodley <cbodley@redhat.com>
This commit is contained in:
Casey Bodley 2023-08-16 12:36:55 -04:00 committed by GitHub
commit 7879630b45
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/rgw/rgw_s3select.cc
View File

@ -445,6 +445,7 @@ int RGWSelectObj_ObjStore_S3::run_s3select_on_csv(const char* query, const char*
} else {
m_aws_response_handler.send_continuation_response();
}
ldpp_dout(this, 10) << "s3-select: complete chunk processing : chunk length = " << input_length << dendl;
if (enable_progress == true) {
fp_chunked_transfer_encoding();
m_aws_response_handler.init_progress_response();
@ -458,7 +459,7 @@ int RGWSelectObj_ObjStore_S3::run_s3select_on_parquet(const char* query)
int status = 0;
#ifdef _ARROW_EXIST
if (!m_s3_parquet_object.is_set()) {
//parsing the SQL statement
//parsing the SQL statement.
s3select_syntax.parse_query(m_sql_query.c_str());
//m_s3_parquet_object.set_external_debug_system(fp_debug_mesg);
try {

2
src/s3select

@ -1 +1 @@
Subproject commit 874752f9cc931b2b0af52e96bcc147e0239faa14
Subproject commit 8f86167c65ccd4f134b6baec0eeb0ed7ea193bf8