You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by yu...@apache.org on 2026/06/17 01:38:34 UTC
(fluss) branch main updated: [test] Fix disk usage collector test (#3491)
This is an automated email from the ASF dual-hosted git repository.
swuferhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 53d127bdc [test] Fix disk usage collector test (#3491)
53d127bdc is described below
commit 53d127bdce12a366b6b2a26d23a09298fc6d98b0
Author: hanliu0830 <ha...@gmail.com>
AuthorDate: Wed Jun 17 09:38:29 2026 +0800
[test] Fix disk usage collector test (#3491)
Co-authored-by: 刘焓 <si...@xiaohongshu.com>
---
.../java/org/apache/fluss/server/storage/DiskUsageCollectorTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/fluss-server/src/test/java/org/apache/fluss/server/storage/DiskUsageCollectorTest.java b/fluss-server/src/test/java/org/apache/fluss/server/storage/DiskUsageCollectorTest.java
index 86b09c6fa..41b1667b8 100644
--- a/fluss-server/src/test/java/org/apache/fluss/server/storage/DiskUsageCollectorTest.java
+++ b/fluss-server/src/test/java/org/apache/fluss/server/storage/DiskUsageCollectorTest.java
@@ -27,6 +27,7 @@ import java.util.Collections;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.assertj.core.data.Offset.offset;
/** Test for {@link DiskUsageCollector}. */
class DiskUsageCollectorTest {
@@ -55,7 +56,7 @@ class DiskUsageCollectorTest {
DiskUsageCollector oneDir = new DiskUsageCollector(Collections.singletonList(dataDir1));
// both directories share the same FileStore -> result should match a single-dir collector
- assertThat(twoDirs.collect()).isEqualTo(oneDir.collect());
+ assertThat(twoDirs.collect()).isCloseTo(oneDir.collect(), offset(1e-6));
}
@Test