Skip to content

Commit 8f5b59b

Browse files
committed
fix build
1 parent 074e9c3 commit 8f5b59b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

ydb/library/yql/providers/yt/provider/yql_yt_io_discovery.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ class TYtIODiscoveryTransformer : public TGraphTransformerBase {
192192
return ctx.ChangeChild(readNode.Ref(), 2, InitializeWalkFolders(std::move(key), cluster, keyPos, ctx));
193193
}
194194
else if (key.GetWalkFolderImplArgs()) {
195-
Y_ENSURE(PendingWalkFoldersKeys_.contains(key.GetWalkFolderImplArgs()->StateKey));
195+
PendingWalkFoldersKeys_.insert(key.GetWalkFolderImplArgs()->StateKey);
196196
}
197197
else if (!key.IsAnonymous()) {
198198
if (PendingCanonizations_.insert(std::make_pair(std::make_pair(cluster, key.GetPath()), paths.size())).second) {
@@ -707,7 +707,7 @@ class TYtIODiscoveryTransformer : public TGraphTransformerBase {
707707
YQL_CLOG(INFO, ProviderYt) << "Failed to parse WalkFolderImpl args";
708708
return {};
709709
}
710-
const auto instanceKey = parsedKey.GetWalkFolderImplArgs()->StateKey;
710+
const ui64 instanceKey = parsedKey.GetWalkFolderImplArgs()->StateKey;
711711
if (*PendingWalkFoldersKeys_.begin() != instanceKey) {
712712
return readNode.Ptr();
713713
}
@@ -865,7 +865,7 @@ class TYtIODiscoveryTransformer : public TGraphTransformerBase {
865865
TWalkFoldersImpl& GetCurrentWalkFoldersInstance() const {
866866
Y_ENSURE(!PendingWalkFoldersKeys_.empty());
867867
const auto key = PendingWalkFoldersKeys_.begin();
868-
auto stateIt = State_->WalkFoldersState.find(key);
868+
auto stateIt = State_->WalkFoldersState.find(*key);
869869
YQL_ENSURE(stateIt != State_->WalkFoldersState.end());
870870
return stateIt->second;
871871
}
@@ -884,7 +884,7 @@ class TYtIODiscoveryTransformer : public TGraphTransformerBase {
884884
THashMap<std::pair<TString, TYtKey::TRange>, std::pair<TPosition, NThreading::TFuture<IYtGateway::TTableRangeResult>>> PendingRanges_;
885885
THashMap<std::pair<TString, TYtKey::TFolderList>, std::pair<TPosition, NThreading::TFuture<IYtGateway::TFolderResult>>> PendingFolders_;
886886
THashMap<std::pair<TString, TString>, size_t> PendingCanonizations_; // cluster, original table path -> positions in canon result
887-
THashSet<ui64> PendingWalkFoldersKeys_;
887+
TSet<ui64> PendingWalkFoldersKeys_;
888888
NThreading::TFuture<IYtGateway::TCanonizePathsResult> CanonizeFuture_;
889889
NThreading::TFuture<void> CanonizationRangesFoldersFuture_;
890890

0 commit comments

Comments
 (0)