Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
BiteTheDDDDt committed Nov 28, 2024
1 parent ce0eded commit a010566
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions be/src/exprs/runtime_filter.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1044,7 +1044,7 @@ class SyncSizeClosure : public AutoReleaseClosure<PSendFilterSizeRequest,

void _process_if_rpc_failed() override {
Defer defer {[&]() { ((pipeline::CountedFinishDependency*)_dependency.get())->sub(); }};
auto ctx = _rf_context.lock();
auto ctx = _rf_context;
if (!ctx) {
return;
}
Expand All @@ -1055,7 +1055,7 @@ class SyncSizeClosure : public AutoReleaseClosure<PSendFilterSizeRequest,

void _process_if_meet_error_status(const Status& status) override {
Defer defer {[&]() { ((pipeline::CountedFinishDependency*)_dependency.get())->sub(); }};
auto ctx = _rf_context.lock();
auto ctx = _rf_context;
if (!ctx) {
return;
}
Expand Down

0 comments on commit a010566

Please sign in to comment.