diff options
| author | Dmitry Kardymon <[email protected]> | 2024-11-01 23:22:22 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-11-01 20:22:22 +0000 |
| commit | f2cdb345c7e9f44fb52849c193756d0febfaa805 (patch) | |
| tree | 3d3cc34b0ff9d11d5826c3adec51704c9b391e49 | |
| parent | 5dad85d4dc6ea41f61125685cea98b042ec3fefd (diff) | |
YQ-3713 Shared reading: do not check compare arguments types (#11140)
| -rw-r--r-- | ydb/library/yql/providers/pq/provider/yql_pq_logical_opt.cpp | 2 | ||||
| -rw-r--r-- | ydb/tests/fq/yds/test_row_dispatcher.py | 10 |
2 files changed, 6 insertions, 6 deletions
diff --git a/ydb/library/yql/providers/pq/provider/yql_pq_logical_opt.cpp b/ydb/library/yql/providers/pq/provider/yql_pq_logical_opt.cpp index 2f75ccb70e6..c65b32a5f44 100644 --- a/ydb/library/yql/providers/pq/provider/yql_pq_logical_opt.cpp +++ b/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); } }; diff --git a/ydb/tests/fq/yds/test_row_dispatcher.py b/ydb/tests/fq/yds/test_row_dispatcher.py index edc7cab8e7d..02fe46b9ffd 100644 --- a/ydb/tests/fq/yds/test_row_dispatcher.py +++ b/ydb/tests/fq/yds/test_row_dispatcher.py @@ -294,10 +294,10 @@ class TestPqRowDispatcher(TestYdsBase): 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 @@ class TestPqRowDispatcher(TestYdsBase): 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) |