File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
priam/src/main/java/com/netflix/priam/aws Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -77,10 +77,15 @@ public boolean hasNext() {
7777 while (objectListing .isTruncated () && !iterator .hasNext ()) {
7878 ListObjectsRequest .Builder listReqBuilder = ListObjectsRequest .builder ()
7979 .bucket (bucket )
80- .prefix (prefix )
81- .marker (objectListing .nextMarker ());
80+ .prefix (prefix );
8281
83- if (StringUtils .isNotBlank (delimiter )) listReqBuilder .delimiter (delimiter );
82+ if (StringUtils .isNotBlank (delimiter )) {
83+ // nextMarker() is only published when delimiter is specified.
84+ listReqBuilder .delimiter (delimiter ).marker (objectListing .nextMarker ());
85+ } else {
86+ String marker = objectListing .contents ().get (objectListing .contents ().size () - 1 ).key ();
87+ listReqBuilder .marker (marker );
88+ }
8489
8590 objectListing = s3Client .listObjects (listReqBuilder .build ());
8691 iterator = createIterator ();
You can’t perform that action at this time.
0 commit comments