aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorilnaz <ilnaz@ydb.tech>2022-07-14 21:29:42 +0300
committerilnaz <ilnaz@ydb.tech>2022-07-14 21:29:42 +0300
commitb63fb26957f120f5cbf2a363d9fef60df2e7c2ae (patch)
tree3378f87ee127b4e566d7fa063dc47f2ba67d5867
parentff0e9f4d6172cfda59e78029da1cd261a4a46e01 (diff)
downloadydb-b63fb26957f120f5cbf2a363d9fef60df2e7c2ae.tar.gz
Remove unnecessary Y_VERIFY()
-rw-r--r--ydb/core/tx/datashard/alter_cdc_stream_unit.cpp1
-rw-r--r--ydb/core/tx/datashard/create_cdc_stream_unit.cpp1
-rw-r--r--ydb/core/tx/datashard/drop_cdc_stream_unit.cpp1
3 files changed, 0 insertions, 3 deletions
diff --git a/ydb/core/tx/datashard/alter_cdc_stream_unit.cpp b/ydb/core/tx/datashard/alter_cdc_stream_unit.cpp
index 3b178306f5..37e372b233 100644
--- a/ydb/core/tx/datashard/alter_cdc_stream_unit.cpp
+++ b/ydb/core/tx/datashard/alter_cdc_stream_unit.cpp
@@ -34,7 +34,6 @@ public:
Y_VERIFY(pathId.OwnerId == DataShard.GetPathOwnerId());
const auto streamPathId = PathIdFromPathId(streamDesc.GetPathId());
- Y_VERIFY(streamPathId.OwnerId == DataShard.GetPathOwnerId());
Y_VERIFY_S(streamDesc.GetState() == NKikimrSchemeOp::ECdcStreamStateDisabled, "Unexpected alter cdc stream"
<< ": desc# " << streamDesc.ShortDebugString());
diff --git a/ydb/core/tx/datashard/create_cdc_stream_unit.cpp b/ydb/core/tx/datashard/create_cdc_stream_unit.cpp
index 490e79f90f..b7cf66b899 100644
--- a/ydb/core/tx/datashard/create_cdc_stream_unit.cpp
+++ b/ydb/core/tx/datashard/create_cdc_stream_unit.cpp
@@ -36,7 +36,6 @@ public:
Y_VERIFY(pathId.OwnerId == DataShard.GetPathOwnerId());
const auto streamPathId = PathIdFromPathId(streamDesc.GetPathId());
- Y_VERIFY(streamPathId.OwnerId == DataShard.GetPathOwnerId());
const auto version = params.GetTableSchemaVersion();
Y_VERIFY(version);
diff --git a/ydb/core/tx/datashard/drop_cdc_stream_unit.cpp b/ydb/core/tx/datashard/drop_cdc_stream_unit.cpp
index 1775888a03..67b676e4e5 100644
--- a/ydb/core/tx/datashard/drop_cdc_stream_unit.cpp
+++ b/ydb/core/tx/datashard/drop_cdc_stream_unit.cpp
@@ -35,7 +35,6 @@ public:
Y_VERIFY(pathId.OwnerId == DataShard.GetPathOwnerId());
const auto streamPathId = PathIdFromPathId(params.GetStreamPathId());
- Y_VERIFY(streamPathId.OwnerId == DataShard.GetPathOwnerId());
const auto version = params.GetTableSchemaVersion();
Y_VERIFY(version);