diff options
| -rw-r--r-- | ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp | 1 | ||||
| -rw-r--r-- | ydb/core/tx/datashard/datashard_kqp_compute.h | 3 | ||||
| -rw-r--r-- | ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp | 1 |
3 files changed, 1 insertions, 4 deletions
diff --git a/ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp b/ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp index ffa56fbe67c..50a3c1f4013 100644 --- a/ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp +++ b/ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp @@ -142,7 +142,6 @@ EExecutionStatus TBuildKqpDataTxOutRSUnit::OnTabletNotReady(TActiveTransaction& { LOG_T("Tablet " << DataShard.TabletID() << " is not ready for " << tx << " execution"); - dataTx.GetKqpComputeCtx().ResetTabletNotReady(); DataShard.IncCounter(COUNTER_TX_TABLET_NOT_READY); ui64 pageFaultCount = tx.IncrementPageFaultCount(); diff --git a/ydb/core/tx/datashard/datashard_kqp_compute.h b/ydb/core/tx/datashard/datashard_kqp_compute.h index 170e555b2ba..4bbb8fa0de7 100644 --- a/ydb/core/tx/datashard/datashard_kqp_compute.h +++ b/ydb/core/tx/datashard/datashard_kqp_compute.h @@ -55,8 +55,7 @@ public: TEngineHostCounters& GetTaskCounters(ui64 taskId) { return TaskCounters[taskId]; } TEngineHostCounters& GetDatashardCounters() { return DatashardCounters; } - void SetTabletNotReady() { TabletNotReady = true; }; - void ResetTabletNotReady() { TabletNotReady = false; } + void SetTabletNotReady() { Y_VERIFY_DEBUG(!TabletNotReady); TabletNotReady = true; }; bool IsTabletNotReady() const { return TabletNotReady; } public: diff --git a/ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp b/ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp index 98ab09de45b..70e7be3662b 100644 --- a/ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp +++ b/ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp @@ -226,7 +226,6 @@ EExecutionStatus TExecuteKqpDataTxUnit::OnTabletNotReady(TActiveTransaction& tx, { LOG_T("Tablet " << DataShard.TabletID() << " is not ready for " << tx << " execution"); - dataTx.GetKqpComputeCtx().ResetTabletNotReady(); DataShard.IncCounter(COUNTER_TX_TABLET_NOT_READY); ui64 pageFaultCount = tx.IncrementPageFaultCount(); |