From 2e357113195eb14248cb4ecb4bf4ddb353b1c75b Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Sun, 27 Oct 2024 01:13:44 +0800 Subject: [PATCH] [COMMON] add size to perf log --- app/src/main/java/org/astraea/app/performance/Performance.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/app/src/main/java/org/astraea/app/performance/Performance.java b/app/src/main/java/org/astraea/app/performance/Performance.java index 1942c6398d..dfb6eafa7f 100644 --- a/app/src/main/java/org/astraea/app/performance/Performance.java +++ b/app/src/main/java/org/astraea/app/performance/Performance.java @@ -130,6 +130,8 @@ public static List execute(final Argument param) { () -> producerThreads.stream().allMatch(AbstractThread::closed), param.logInterval, List.of( + ReportFormat.CSVContentElement.create( + "size", () -> String.valueOf(sizes.get().sum())), ReportFormat.CSVContentElement.create( "max size", () -> String.valueOf(sizes.get().max().getAsLong())), ReportFormat.CSVContentElement.create(