(camel-quarkus) branch main updated: Added some small logs to Aws2KinesisFirehoseTest for better understanding of flaky tests (#6186)

[zhfeng]

This is an automated email from the ASF dual-hosted git repository.

zhfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new ce6d4b642a Added some small logs to Aws2KinesisFirehoseTest for better 
understanding of flaky tests (#6186)
ce6d4b642a is described below

commit ce6d4b642abff4c8929053b8894f15729efe6c51
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Fri Jun 14 01:51:45 2024 +0200

    Added some small logs to Aws2KinesisFirehoseTest for better understanding 
of flaky tests (#6186)
---
 .../quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java  | 3 ++-
 .../component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java     | 6 +++++-
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java
 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java
index 0524a5dfd6..b16c505952 100644
--- 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java
+++ 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java
@@ -83,9 +83,10 @@ class Aws2KinesisFirehoseTest extends BaseAWs2TestSupport {
         final Config config = ConfigProvider.getConfig();
 
         final String bucketName = 
config.getValue("aws-kinesis.s3-bucket-name", String.class);
-
+        LOG.infof("Bucket '%s' should contain objects.", bucketName);
         Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120, 
TimeUnit.SECONDS).until(
                 () -> {
+                    LOG.infof("Reading objects from bucket '%s'", bucketName);
                     final ListObjectsResponse objects = client
                             
.listObjects(ListObjectsRequest.builder().bucket(bucketName).build());
                     final List<S3Object> objs = objects.contents();
diff --git 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java
 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java
index 353cb8e075..0be68ae047 100644
--- 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java
+++ 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java
@@ -122,8 +122,12 @@ public class Aws2KinesisTestEnvCustomizer implements 
Aws2TestEnvCustomizer {
             final String bucketArn = "arn:aws:s3:::" + bucketName;
             envContext.property("aws-kinesis.s3-bucket-name", bucketName);
             
s3Client.createBucket(CreateBucketRequest.builder().bucket(bucketName).build());
-            envContext.closeable(() -> 
s3Client.deleteBucket(DeleteBucketRequest.builder().bucket(bucketName).build()));
             envContext.closeable(() -> {
+                LOG.info("Deleting bucket " + bucketName);
+                
s3Client.deleteBucket(DeleteBucketRequest.builder().bucket(bucketName).build());
+            });
+            envContext.closeable(() -> {
+                LOG.info("Deleting objects from bucket bucket " + bucketName);
                 final ListObjectsResponse objects = s3Client.listObjects(
                         ListObjectsRequest.builder()
                                 .bucket(bucketName)