Fix for issue apache#4714

mattcasters · Dec 16, 2024 · d4b5be4 · d4b5be4
1 parent fe080d9
commit d4b5be4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/tech/avro/src/main/java/org/apache/hop/avro/transforms/avroinput/AvroFileInput.java b/plugins/tech/avro/src/main/java/org/apache/hop/avro/transforms/avroinput/AvroFileInput.java
@@ -95,7 +95,7 @@ public boolean processRow() throws HopException {
       try (InputStream inputStream = HopVfs.getInputStream(filename, variables)) {
         GenericDatumReader<GenericRecord> datumReader = new GenericDatumReader<>();
         DataFileStream<GenericRecord> fileStream = new DataFileStream<>(inputStream, datumReader);
-        while (fileStream.hasNext()) {
+        while (fileStream.hasNext() && !isStopped()) {
           GenericRecord genericRecord = fileStream.next();
           incrementLinesInput();