diff --git a/nifi-huawei-processors/src/main/java/org/apache/nifi/processors/huawei/obs/ListOBSObject.java b/nifi-huawei-processors/src/main/java/org/apache/nifi/processors/huawei/obs/ListOBSObject.java index 3bf50e8e25aa3561c02154ca504e092c3a94eddf..53290b71be257c8ad9493d1339710c58a08b0b01 100644 --- a/nifi-huawei-processors/src/main/java/org/apache/nifi/processors/huawei/obs/ListOBSObject.java +++ b/nifi-huawei-processors/src/main/java/org/apache/nifi/processors/huawei/obs/ListOBSObject.java @@ -150,7 +150,7 @@ public class ListOBSObject extends AbstractListHuaweiProcessor { ObsBucketLister bucketLister = new OBSObjectBucketLister(client, context); do { ListVersionsResult versionListing = bucketLister.listVersions(); - getLogger().warn("ListVersionsResult count : {}", versionListing.getVersions().length); + for (VersionOrDeleteMarker versionSummary : versionListing.getVersions()) { if (!isFileInfoMatchesWithAgeAndSize(context, minimumTimestamp, versionSummary.getLastModified().getTime(), versionSummary.getSize())) { continue; @@ -164,6 +164,7 @@ public class ListOBSObject extends AbstractListHuaweiProcessor { list.add(record); batchCount++; } + getLogger().warn("ListVersionsResult count : {}/{}", batchCount, versionListing.getVersions().length); bucketLister.setNextMarker(); getLogger().info("Successfully listed {} new files from OBS; routing to success", batchCount); batchCount = 0;