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);