Added some small logs to Aws2KinesisFirehoseTest for better understan…

…ding of flaky tests
apache · Jun 13, 2024 · 87003ef · 87003ef
1 parent dbb1c41
commit 87003ef
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/...test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java b/...test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisFirehoseTest.java
@@ -83,9 +83,10 @@ public void firehose() {
         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/...java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java b/...java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTestEnvCustomizer.java
@@ -122,8 +122,12 @@ public void customize(Aws2TestEnvContext envContext) {
             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)