From a0b6dd5395e917b4fa02357efb34ee95ab714d56 Mon Sep 17 00:00:00 2001 From: Radu Grigore Date: Sun, 11 Oct 2020 09:35:20 +0100 Subject: [PATCH] Fix in RedissonExecutorService When wrapping an OutputStream around a ByteArrayOutputStream, it is safer to flush. See, for example, https://stackoverflow.com/questions/2984538/how-to-use-bytearrayoutputstream-and-dataoutputstream-simultaneously-java --- .../src/main/java/org/redisson/RedissonExecutorService.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/redisson/src/main/java/org/redisson/RedissonExecutorService.java b/redisson/src/main/java/org/redisson/RedissonExecutorService.java index f8834d850..30a3c4630 100644 --- a/redisson/src/main/java/org/redisson/RedissonExecutorService.java +++ b/redisson/src/main/java/org/redisson/RedissonExecutorService.java @@ -429,6 +429,8 @@ public class RedissonExecutorService implements RScheduledExecutorService { try { ObjectOutput oo = new ObjectOutputStream(os); oo.writeObject(task); + oo.flush(); + oo.close(); } catch (Exception e) { throw new IllegalArgumentException("Unable to serialize lambda", e); }