This is an automated email from the ASF dual-hosted git repository.
hongze pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new c6198f0a07 [GLUTEN-7572][CORE] Check if iterator has been closed
(#7573)
c6198f0a07 is described below
commit c6198f0a07094bb8de43fad6b10b61fc24833b6b
Author: Zhen Wang <[email protected]>
AuthorDate: Fri Oct 18 14:51:52 2024 +0800
[GLUTEN-7572][CORE] Check if iterator has been closed (#7573)
---
.../src/main/java/org/apache/gluten/iterator/ClosableIterator.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/gluten-core/src/main/java/org/apache/gluten/iterator/ClosableIterator.java
b/gluten-core/src/main/java/org/apache/gluten/iterator/ClosableIterator.java
index 6123a4a527..6ed9d6c180 100644
--- a/gluten-core/src/main/java/org/apache/gluten/iterator/ClosableIterator.java
+++ b/gluten-core/src/main/java/org/apache/gluten/iterator/ClosableIterator.java
@@ -32,6 +32,9 @@ public abstract class ClosableIterator
@Override
public final boolean hasNext() {
+ if (closed.get()) {
+ throw new GlutenException("Iterator has been closed.");
+ }
try {
return hasNext0();
} catch (Exception e) {
@@ -41,6 +44,9 @@ public abstract class ClosableIterator
@Override
public final ColumnarBatch next() {
+ if (closed.get()) {
+ throw new GlutenException("Iterator has been closed.");
+ }
try {
return next0();
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
