Github user ijokarumawak commented on a diff in the pull request: https://github.com/apache/nifi/pull/2361#discussion_r159118001 --- Diff: nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java --- @@ -264,18 +265,19 @@ public void onTrigger(final ProcessContext context, final ProcessSession session } bucketLister.setNextMarker(); + totalListCount += listCount; commit(context, session, listCount); listCount = 0; } while (bucketLister.isTruncated()); + + // Update stateManger with the most recent timestamp currentTimestamp = maxTimestamp; + persistState(context); final long listMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNanos); getLogger().info("Successfully listed S3 bucket {} in {} millis", new Object[]{bucket, listMillis}); - if (!commit(context, session, listCount)) { - if (currentTimestamp > 0) { - persistState(context); - } + if (totalListCount == 0) { --- End diff -- Good catch!
---