This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch fix_null_pointer_in_cluster in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit efe70c0c3363fb4be04f48532891186eb53f2c69 Author: qiaojialin <[email protected]> AuthorDate: Sat Jul 3 17:55:46 2021 +0800 fix take byte array null pointer in PlanSerializer --- .../main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java b/cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java index 71b3136..78200f0 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/utils/PlanSerializer.java @@ -35,7 +35,13 @@ public class PlanSerializer { } public byte[] serialize(PhysicalPlan plan) throws IOException { - ByteArrayOutputStream poll = baosBlockingDeque.poll(); + ByteArrayOutputStream poll; + try { + poll = baosBlockingDeque.take(); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + throw new IOException("take byte array output stream interrupted", e); + } poll.reset(); try (DataOutputStream dataOutputStream = new DataOutputStream(poll)) {
