From: galsalomon66 <gal.salomon@gmail.com>
Date: Sun, 25 Jun 2023 22:10:38 +0000 (+0300)
Subject: - s3select fixes, related to Trino/TPCDS benchmark
X-Git-Tag: v19.0.0~671^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=87739031fd4979d1310eea48c9d5cd414bc76a4d;p=ceph.git

- s3select fixes, related to Trino/TPCDS benchmark
- s3select submodule
- add log-message for better tracing the flow timeline
- fix valgrind issue
- new s3select version. fix crash upon wrong initialization on JSON flow
- s3select module. a fix for a constant number of columns(128).
- s3select module. QE fixes

Signed-off-by: galsalomon66 <gal.salomon@gmail.com>
---

diff --git a/src/rgw/rgw_s3select.cc b/src/rgw/rgw_s3select.cc
index 7d93569f3a4c..c7eaa69842f3 100644
--- a/src/rgw/rgw_s3select.cc
+++ b/src/rgw/rgw_s3select.cc
@@ -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 {
diff --git a/src/s3select b/src/s3select
index 874752f9cc93..8f86167c65cc 160000
--- a/src/s3select
+++ b/src/s3select
@@ -1 +1 @@
-Subproject commit 874752f9cc931b2b0af52e96bcc147e0239faa14
+Subproject commit 8f86167c65ccd4f134b6baec0eeb0ed7ea193bf8