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
index 2584142fa88..213cf72ba9b 100644
--- 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();