aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgvit <gvit@ydb.tech>2023-08-25 15:33:11 +0300
committergvit <gvit@ydb.tech>2023-08-25 15:54:14 +0300
commitefe6854ee705493580e853fa841afacc98a6a3c3 (patch)
tree12e6de1c866a58669201e3290991480e5b4ab151
parent23d486d4567e20edacdaae8e4c9489be9bd3f15b (diff)
downloadydb-efe6854ee705493580e853fa841afacc98a6a3c3.tar.gz
one more attempt to fix test KIKIMR-19028
-rw-r--r--ydb/core/kqp/ut/arrow/kqp_arrow_in_channels_ut.cpp2
-rw-r--r--ydb/core/kqp/ut/arrow/kqp_types_arrow_ut.cpp2
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());
}
}