| 1 | diff --git a/src/execution/operator/join/physical_iejoin.cpp b/src/execution/operator/join/physical_iejoin.cpp
|
| 2 | index fd392f3b9d..ecb89363ad 100644
|
| 3 | |
| 4 | |
| 5 | @@ -1367,6 +1367,9 @@ void IEJoinGlobalSourceState::Initialize() {
|
| 6 |
|
| 7 | bool IEJoinGlobalSourceState::TryPrepareNextStage() {
|
| 8 | // Inside lock
|
| 9 | + if (stage == IEJoinSourceStage::DONE) {
|
| 10 | + return true;
|
| 11 | + }
|
| 12 | const auto stage_count = GetStageCount(stage);
|
| 13 | const auto stage_next = GetStageNext(stage).load();
|
| 14 | if (stage_next >= stage_count) {
|