Skip to content

Commit 41c9e98

Browse files
committed
Move EvRemoveOldTmp sending and remove its handling in broken state
1 parent 48a5d9e commit 41c9e98

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

ydb/library/yql/dq/actors/spilling/spilling_file.cpp

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -221,13 +221,12 @@ class TDqLocalFileSpillingService : public TActorBootstrapped<TDqLocalFileSpilli
221221

222222
void Bootstrap() {
223223
Root_ = Config_.Root;
224+
const auto rootToRemoveOldTmp = Root_;
224225
const auto sessionId = Config_.SpillingSessionId;
225226
const auto nodeId = SelfId().NodeId();
226227

227-
Send(SelfId(), MakeHolder<TEvPrivate::TEvRemoveOldTmp>(Root_, nodeId, sessionId));
228-
229228
Root_ /= (TStringBuilder() << "node_" << nodeId << "_" << sessionId);
230-
Cerr << "Root from config: " << Config_.Root << ", actual root: " << Root_ << "\n";
229+
// Cerr << "Root from config: " << Config_.Root << ", actual root: " << Root_ << "\n";
231230
LOG_I("Init DQ local file spilling service at " << Root_ << ", actor: " << SelfId());
232231

233232
try {
@@ -241,6 +240,8 @@ class TDqLocalFileSpillingService : public TActorBootstrapped<TDqLocalFileSpilli
241240
Become(&TDqLocalFileSpillingService::BrokenState);
242241
return;
243242
}
243+
244+
Send(SelfId(), MakeHolder<TEvPrivate::TEvRemoveOldTmp>(Root_, nodeId, sessionId));
244245

245246
Become(&TDqLocalFileSpillingService::WorkState);
246247
}
@@ -268,8 +269,6 @@ class TDqLocalFileSpillingService : public TActorBootstrapped<TDqLocalFileSpilli
268269
}
269270
hFunc(NMon::TEvHttpInfo, HandleBroken);
270271
cFunc(TEvents::TEvPoison::EventType, PassAway);
271-
case TEvPrivate::TEvRemoveOldTmp::EventType:
272-
break;
273272
default:
274273
Y_DEBUG_ABORT_UNLESS(false, "%s: unexpected message type 0x%08" PRIx32, __func__, ev->GetTypeRewrite());
275274
}

0 commit comments

Comments
 (0)