From 68f5c8da5e3d6918dfc1e914127c64540eee3c79 Mon Sep 17 00:00:00 2001 From: Steve Loughran Date: Sun, 21 Jan 2024 18:56:32 +0000 Subject: [PATCH] HADOOP-19043. Code review; print stream which doesn't make closed/open assert. Change-Id: I35ba5f0b6cba67967dc945326944cb2cf942c2e8 --- .../apache/hadoop/fs/s3a/performance/ITestS3AOpenCost.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/performance/ITestS3AOpenCost.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/performance/ITestS3AOpenCost.java index 35c45b183fc6f..25ffc8fda81cb 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/performance/ITestS3AOpenCost.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/performance/ITestS3AOpenCost.java @@ -477,13 +477,13 @@ private static void assertS3StreamClosed(final FSDataInputStream in) { if (wrapped instanceof S3AInputStream) { S3AInputStream s3ain = (S3AInputStream) wrapped; Assertions.assertThat(s3ain.isObjectStreamOpen()) - .describedAs("stream is open") + .describedAs("stream is open: %s", s3ain) .isFalse(); } } /** - * Assert that the inner S3 Stream is open. + * Assert that the inner S3 Stream is closed. * @param in input stream */ private static void assertS3StreamOpen(final FSDataInputStream in) { @@ -491,7 +491,7 @@ private static void assertS3StreamOpen(final FSDataInputStream in) { if (wrapped instanceof S3AInputStream) { S3AInputStream s3ain = (S3AInputStream) wrapped; Assertions.assertThat(s3ain.isObjectStreamOpen()) - .describedAs("stream is closed") + .describedAs("stream is closed: %s", s3ain) .isTrue(); } }