Minor changes

Author: vitalyisaev2

app/server/config/config.debug.yaml

@@ -4,7 +4,7 @@ connector_server:
     port: 2130
 
 logger:
-  log_level: DEBUG
+  log_level: INFO
   enable_sql_query_logging: true
 
 metrics_server:
@@ -78,7 +78,8 @@ datasources:
   ydb:
     <<: *data_source_default_var
     use_underlay_network_for_dedicated_databases: false
-    mode: MODE_QUERY_SERVICE_NATIVE_ARROW
+    #mode: MODE_QUERY_SERVICE_NATIVE_ARROW
+    mode: MODE_QUERY_SERVICE_NATIVE
     pushdown:
       enable_timestamp_pushdown: true
 

app/server/streaming/read_splits_streamer.go

@@ -65,7 +65,6 @@ func (s *ReadSplitsStreamer[T]) sendResultToStream(result *paging.ReadResult[T])
 	var err error
 
 	if result.Data != nil {
-		fmt.Println(" >>> HERE <<<")
 		// Handle the case where we have serialized Arrow data
 		resp = &api_service_protos.TReadSplitsResponse{
 			Payload: &api_service_protos.TReadSplitsResponse_ArrowIpcStreaming{

scripts/debug/kqprun/script.YQ-4416.txt

@@ -1,4 +1,21 @@
 PRAGMA generic.UsePredicatePushdown="true";
 
-SELECT * FROM external_datasource.olap_lineitem_s10 LIMIT 10;
+SELECT
+    MIN(l_comment),
+    MIN(l_commitdate),
+    MIN(l_discount),
+    MIN(l_extendedprice),
+    MIN(l_linenumber),
+    MIN(l_linestatus),
+    MIN(l_orderkey),
+    MIN(l_partkey),
+    MIN(l_quantity),
+    MIN(l_receiptdate),
+    MIN(l_returnflag),
+    MIN(l_shipdate),
+    MIN(l_shipinstruct),
+    MIN(l_shipmode),
+    MIN(l_suppkey),
+    MIN(l_tax)
+FROM (SELECT * FROM external_datasource.olap_lineitem_s10 LIMIT 10000000);