diff --git a/app/src/main/java/org/astraea/app/performance/TrackerThread.java b/app/src/main/java/org/astraea/app/performance/TrackerThread.java index 58218a373a..be0e02bdd5 100644 --- a/app/src/main/java/org/astraea/app/performance/TrackerThread.java +++ b/app/src/main/java/org/astraea/app/performance/TrackerThread.java @@ -191,8 +191,8 @@ public boolean closed() { public void close() { closed.set(true); waitForDone(); - producerReceiver.close(); - consumerReceiver.close(); + Utils.packException(producerReceiver::close); + Utils.packException(consumerReceiver::close); } }; }