change to unbounded

wayneguow · Jun 12, 2024 · 541e5b4 · 541e5b4
1 parent ca916f7
commit 541e5b4
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlInputFormat.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/xml/XmlInputFormat.scala
@@ -119,7 +119,6 @@ private[xml] class XmlRecordReader extends RecordReader[LongWritable, Text] {
       fsin.seek(start)
       countingIn = BoundedInputStream.builder()
         .setInputStream(fsin)
-        .setMaxCount(fileSplit.getLength)
         .get()
       in = countingIn
       // don't use filePosition in this case. We have to count bytes read manually