diff options
| author | ilnaz <[email protected]> | 2022-07-14 21:29:42 +0300 |
|---|---|---|
| committer | ilnaz <[email protected]> | 2022-07-14 21:29:42 +0300 |
| commit | b63fb26957f120f5cbf2a363d9fef60df2e7c2ae (patch) | |
| tree | 3378f87ee127b4e566d7fa063dc47f2ba67d5867 | |
| parent | ff0e9f4d6172cfda59e78029da1cd261a4a46e01 (diff) | |
Remove unnecessary Y_VERIFY()
| -rw-r--r-- | ydb/core/tx/datashard/alter_cdc_stream_unit.cpp | 1 | ||||
| -rw-r--r-- | ydb/core/tx/datashard/create_cdc_stream_unit.cpp | 1 | ||||
| -rw-r--r-- | ydb/core/tx/datashard/drop_cdc_stream_unit.cpp | 1 |
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 3b178306f57..37e372b2335 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 490e79f90f8..b7cf66b8992 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 1775888a034..67b676e4e5f 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); |