Skip to content

Commit e383de8

Browse files
tkaymakTobias Kaymak
authored andcommitted
Remove unused endOfData() call in close method
Remove endOfData() call in close method.
1 parent 43bcd98 commit e383de8

1 file changed

Lines changed: 0 additions & 1 deletion

File tree

runners/spark/4/src/main/java/org/apache/beam/runners/spark/structuredstreaming/io/BoundedDatasetFactory.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -284,7 +284,6 @@ public SourcePartitionIterator(SourcePartition<T> partition, Params<T> params) {
284284
@SuppressWarnings("nullness") // ok, reader not used any longer
285285
public void close() throws IOException {
286286
if (reader != null) {
287-
endOfData();
288287
try {
289288
reader.close();
290289
} finally {

0 commit comments

Comments
 (0)