This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 628271e08ff6083ea75fcf3f7b166997a2d14c16 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Apr 13 14:35:17 2021 +0200 CAMEL-16495 - Camel-AWS-S3 - Streaming upload: While restarting the listObject operation should be paginated --- .../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java index e1121fc..d1394f1 100644 --- a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java +++ b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java @@ -306,9 +306,8 @@ public class AWS2S3StreamUploadProducer extends DefaultProducer { .build(); } if (list.size() > 0) { - list.sort(Comparator.comparing(S3Object::lastModified)); - int listSize = list.size(); - String fileName = AWS2S3Utils.determineFileName(list.get(listSize - 1).key()); + list.sort(Comparator.comparing(S3Object::key)); + String fileName = AWS2S3Utils.determineFileName(list.get(0).key()); int position = fileName.lastIndexOf("-"); if (position != -1) { String partString = fileName.substring(position + 1);
