fix ut after merge

Author: zverevgeny

ydb/core/kqp/ut/data_integrity/kqp_data_integrity_trails_ut.cpp

@@ -122,7 +122,7 @@ Y_UNIT_TEST_SUITE(KqpDataIntegrityTrails) {
             UNIT_ASSERT_VALUES_EQUAL(CountSubstr(ss.Str(), "DATA_INTEGRITY INFO: Component: WriteActor"), 3);
             if (useOltpSink) {
                 // check executer logs
-                UNIT_ASSERT_VALUES_EQUAL(CountSubstr(ss.Str(), "DATA_INTEGRITY INFO: Component: Executer"), 0);
+                UNIT_ASSERT_VALUES_EQUAL(CountSubstr(ss.Str(), "DATA_INTEGRITY INFO: Component: Executer"), 1);
             } else {
                 // check executer logs
             }

ydb/core/kqp/ut/opt/kqp_ne_ut.cpp

@@ -1905,13 +1905,6 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
         if (UseSink) {
             UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 1);
 
-            // Phase reading rows to delete
-            UNIT_ASSERT(stats.query_phases(0).duration_us() > 0);
-            UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 1);
-            UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/TwoShard");
-            UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 6);
-            UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 2);
-
             // Phase reading rows to delete
             UNIT_ASSERT(stats.query_phases(0).duration_us() > 0);
             UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 1);