aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorIgor Makunin <igor.makunin@gmail.com>2022-02-10 15:16:47 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 15:58:17 +0300
commit6751af0b0c1b952fede40b19b71da8025b5d8bcf (patch)
treef4b34f87f448371f55f9550749d6e3c196cf4a69
parentdade832999b60a3b226b79a1a9099fad1404d433 (diff)
downloadydb-6751af0b0c1b952fede40b19b71da8025b5d8bcf.tar.gz
KIKIMR-13802: drop useless method
ref:48cb620128d8bbbb71c89ebffd317fa6b53f2ae5
-rw-r--r--ydb/core/tx/datashard/build_kqp_data_tx_out_rs_unit.cpp1
-rw-r--r--ydb/core/tx/datashard/datashard_kqp_compute.h3
-rw-r--r--ydb/core/tx/datashard/execute_kqp_data_tx_unit.cpp1
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 ffa56fbe67..50a3c1f401 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 170e555b2b..4bbb8fa0de 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 98ab09de45..70e7be3662 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();