Skip to content

Commit

Permalink
[Kernel] Fix the infinite loop in CloseableIterator.map (delta-io#3071
Browse files Browse the repository at this point in the history
)

## Description

`CloseableIterator.map` creates new `CloseableIterator` which has wrong
`forEachRemaining` impl (it calls itself). We should remove the impl and
fall back on the default impl. This is a day 0 bug, not needed for 3.2
(given 3.2 is so close to release)
  • Loading branch information
vkorukanti authored May 8, 2024
1 parent 3c6f18e commit 40b8f97
Showing 1 changed file with 0 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
import java.io.IOException;
import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.function.Consumer;
import java.util.function.Function;

import io.delta.kernel.annotation.Evolving;
Expand All @@ -43,11 +42,6 @@ public void remove() {
delegate.remove();
}

@Override
public void forEachRemaining(Consumer<? super U> action) {
this.forEachRemaining(action);
}

@Override
public boolean hasNext() {
return delegate.hasNext();
Expand Down

0 comments on commit 40b8f97

Please sign in to comment.