Skip to content

Commit 2cdcbe9

Browse files
committed
Fixed commit offset for pqv0
1 parent 86be04f commit 2cdcbe9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1933,7 +1933,8 @@ void TPartitionActor::SendCommit(const ui64 readId, const ui64 offset, const TAc
19331933
}
19341934
NKikimr::NGRpcProxy::V1::TDistributedCommitHelper::TCommitInfo commit {.PartitionId = Partition, .Offset = (i64)offset, .KillReadSession = false, .OnlyCheckCommitedToFinish = false, .ReadSessionId = Session};
19351935
commits.push_back(commit);
1936-
auto kqp = std::make_shared<NKikimr::NGRpcProxy::V1::TDistributedCommitHelper>(Database, InternalClientId, Topic->GetPrimaryPath(), commits, readId);
1936+
auto database = Database.empty() ? NKikimr::NPQ::GetDatabaseFromConfig(AppData(ctx)->PQConfig) : Database;
1937+
auto kqp = std::make_shared<NKikimr::NGRpcProxy::V1::TDistributedCommitHelper>(database, InternalClientId, Topic->GetPrimaryPath(), commits, readId);
19371938
Kqps.emplace(readId, kqp);
19381939

19391940
kqp->SendCreateSessionRequest(ctx);

0 commit comments

Comments
 (0)