fix splits signal (ydb-platform#7273)

GrigoriyPA · Jul 31, 2024 · bd81a67 · bd81a67
1 parent 3c1690d
commit bd81a67
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp
@@ -75,6 +75,7 @@ class TKqpReadActor : public TActorBootstrapped<TKqpReadActor>, public NYql::NDq
 
         TMaybe<ui32> NodeId = {};
         bool IsFirst = false;
+        bool IsFake = false;
 
 
         TShardState(ui64 tabletId)
@@ -439,6 +440,7 @@ class TKqpReadActor : public TActorBootstrapped<TKqpReadActor>, public NYql::NDq
         CA_LOG_D("Shards State: " << state.ToString(KeyColumnTypes));
 
         if (!Settings->HasShardIdHint()) {
+            state.IsFake = true;
             InFlightShards.PushBack(&state);
             ResolveShard(&state);
         } else {
@@ -679,7 +681,9 @@ class TKqpReadActor : public TActorBootstrapped<TKqpReadActor>, public NYql::NDq
         }
 
         YQL_ENSURE(!newShards.empty());
-        Counters->IteratorsReadSplits->Add(newShards.size() - 1);
+        if (!state->IsFake) {
+            Counters->IteratorsReadSplits->Add(newShards.size() - 1);
+        }
         if (Settings->GetReverse()) {
             for (size_t i = 0; i < newShards.size(); ++i) {
                 PendingShards.PushBack(newShards[i].Release());