We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e3079d commit 67cf548Copy full SHA for 67cf548
1 file changed
cpp/velox/memory/GlutenDirectBufferedInput.h
@@ -48,6 +48,11 @@ class GlutenDirectBufferedInput : public facebook::velox::dwio::common::DirectBu
48
49
~GlutenDirectBufferedInput() override {
50
requests_.clear();
51
+ for (auto& load : coalescedLoads_) {
52
+ if (load->state() == facebook::velox::cache::CoalescedLoad::State::kPlanned) {
53
+ load->cancel();
54
+ }
55
56
for (auto& load : coalescedLoads_) {
57
if (load->state() == facebook::velox::cache::CoalescedLoad::State::kLoading) {
58
folly::SemiFuture<bool> waitFuture(false);
@@ -56,7 +61,6 @@ class GlutenDirectBufferedInput : public facebook::velox::dwio::common::DirectBu
61
std::move(waitFuture).via(&exec).wait();
62
}
63
59
- load->cancel();
60
64
65
coalescedLoads_.clear();
66
0 commit comments