From 0a97ceedac21fe402ca70c2b663b499505ef7f27 Mon Sep 17 00:00:00 2001 From: Ayush Saluja Date: Mon, 16 Jun 2025 20:58:18 +0530 Subject: [PATCH 1/3] Update ListenableFutureUtil.java --- .../java/com/linkedin/parseq/guava/ListenableFutureUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java index db13131b..72e35fb9 100644 --- a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java +++ b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java @@ -47,7 +47,7 @@ public boolean cancel(Exception rootReason) { if (shouldCancelTask && !future.isCancelled()) { boolean futureCancelResult = future.cancel(true); if (!futureCancelResult) { - LOGGER.warn("Unexpected: GRPC future was not cancelled but new attempt to cancel also failed."); + LOGGER.warn("Unexpected: Task {} future was not cancelled but new attempt to cancel also failed.", future.getClass.getName()); } } return shouldCancelTask; From 3d2d6f7ca22969e57939430ac99ff605d5ece087 Mon Sep 17 00:00:00 2001 From: Ayush Saluja Date: Thu, 26 Jun 2025 15:24:59 +0530 Subject: [PATCH 2/3] Update ListenableFutureUtil.java --- .../java/com/linkedin/parseq/guava/ListenableFutureUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java index 72e35fb9..19b5c9be 100644 --- a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java +++ b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java @@ -47,7 +47,7 @@ public boolean cancel(Exception rootReason) { if (shouldCancelTask && !future.isCancelled()) { boolean futureCancelResult = future.cancel(true); if (!futureCancelResult) { - LOGGER.warn("Unexpected: Task {} future was not cancelled but new attempt to cancel also failed.", future.getClass.getName()); + LOGGER.warn("Unexpected: ListenableFuture was not cancelled but new attempt to cancel also failed."); } } return shouldCancelTask; From f433905e850f5286c9743c3c5b62605c210120e4 Mon Sep 17 00:00:00 2001 From: Ayush Saluja Date: Thu, 26 Jun 2025 15:26:03 +0530 Subject: [PATCH 3/3] Update ListenableFutureUtil.java --- .../java/com/linkedin/parseq/guava/ListenableFutureUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java index 19b5c9be..0fc197cb 100644 --- a/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java +++ b/subprojects/parseq-guava-interop/src/main/java/com/linkedin/parseq/guava/ListenableFutureUtil.java @@ -47,7 +47,7 @@ public boolean cancel(Exception rootReason) { if (shouldCancelTask && !future.isCancelled()) { boolean futureCancelResult = future.cancel(true); if (!futureCancelResult) { - LOGGER.warn("Unexpected: ListenableFuture was not cancelled but new attempt to cancel also failed."); + LOGGER.warn("Unexpected: Listenable future was not cancelled but new attempt to cancel also failed."); } } return shouldCancelTask;