diff options
| author | gvit <gvit@ydb.tech> | 2023-08-25 15:33:11 +0300 |
|---|---|---|
| committer | gvit <gvit@ydb.tech> | 2023-08-25 15:54:14 +0300 |
| commit | efe6854ee705493580e853fa841afacc98a6a3c3 (patch) | |
| tree | 12e6de1c866a58669201e3290991480e5b4ab151 | |
| parent | 23d486d4567e20edacdaae8e4c9489be9bd3f15b (diff) | |
| download | ydb-efe6854ee705493580e853fa841afacc98a6a3c3.tar.gz | |
one more attempt to fix test KIKIMR-19028
| -rw-r--r-- | ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp | 2 |
2 files changed, 0 insertions, 4 deletions
diff --git a/ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp b/ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp index 51e2bfbbb7..fbd21d6a39 100644 --- a/ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp +++ b/ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp @@ -84,8 +84,6 @@ void InsertAllColumnsAndCheckSelectAll(TKikimrRunner* runner) { UNIT_ASSERT(*parser.ColumnParser(16).GetOptionalYson().Get() == TString("[13]")); UNIT_ASSERT(*parser.ColumnParser(17).GetOptionalJsonDocument().Get() == TString("[14]")); UNIT_ASSERT(*parser.ColumnParser(18).GetOptionalDyNumber().Get() == TString(".1515e2")); - streamPart = it.ReadNext().GetValueSync(); - UNIT_ASSERT_C(streamPart.EOS() || streamPart.HasQueryStats(), streamPart.GetIssues().ToString()); } } diff --git a/ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp b/ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp index d5abf13d62..71f991355b 100644 --- a/ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp +++ b/ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp @@ -90,8 +90,6 @@ void InsertAllColumnsAndCheckSelectAll(TKikimrRunner* runner) { UNIT_ASSERT(*parser.ColumnParser(16).GetOptionalYson().Get() == TString("[13]")); UNIT_ASSERT(*parser.ColumnParser(17).GetOptionalJsonDocument().Get() == TString("[14]")); UNIT_ASSERT(*parser.ColumnParser(18).GetOptionalDyNumber().Get() == TString(".1515e2")); - streamPart = it.ReadNext().GetValueSync(); - UNIT_ASSERT_C(streamPart.EOS() || streamPart.HasQueryStats(), streamPart.GetIssues().ToString()); } } |