YQ-3713 Shared reading: do not check compare arguments types (#11140)

Author: kardymonds

ydb/library/yql/providers/pq/provider/yql_pq_logical_opt.cpp

@@ -27,7 +27,7 @@ namespace {
             : NPushdown::TSettings(NLog::EComponent::ProviderGeneric)
         {
             using EFlag = NPushdown::TSettings::EFeatureFlag;
-            Enable(EFlag::ExpressionAsPredicate | EFlag::ArithmeticalExpressions | EFlag::ImplicitConversionToInt64 | EFlag::StringTypes | EFlag::LikeOperator);
+            Enable(EFlag::ExpressionAsPredicate | EFlag::ArithmeticalExpressions | EFlag::ImplicitConversionToInt64 | EFlag::StringTypes | EFlag::LikeOperator | EFlag::DoNotCheckCompareArgumentsTypes);
         }
     };
 

ydb/tests/fq/yds/test_row_dispatcher.py

@@ -294,10 +294,10 @@ def test_filter(self, kikimr, client):
             INSERT INTO {YDS_CONNECTION}.`{self.output_topic}`
             SELECT Cast(time as String) FROM {YDS_CONNECTION}.`{self.input_topic}`
                 WITH (format=json_each_row, SCHEMA (time UInt64 NOT NULL, data String NOT NULL, event String NOT NULL))
-                WHERE time > 101UL and 
-                      data = "hello2" and 
-                    event IS NOT DISTINCT FROM "event2" and
-                    event IS DISTINCT FROM "event1";'''
+                WHERE time > 101 and
+                      data = "hello2" and
+                      event IS NOT DISTINCT FROM "event2" and
+                      event IS DISTINCT FROM "event1";'''
 
         query_id = start_yds_query(kikimr, client, sql)
         wait_actor_count(kikimr, "FQ_ROW_DISPATCHER_SESSION", 1)
@@ -577,7 +577,7 @@ def test_stop_start_with_filter(self, kikimr, client):
             INSERT INTO {YDS_CONNECTION}.`{output_topic}`
             SELECT Cast(time as String) FROM {YDS_CONNECTION}.`{self.input_topic}`
                 WITH (format=json_each_row, SCHEMA (time UInt64 NOT NULL))
-                WHERE time > 200UL;'''
+                WHERE time > 200;'''
 
         query_id = start_yds_query(kikimr, client, sql)
         wait_actor_count(kikimr, "FQ_ROW_DISPATCHER_SESSION", 1)