From 7cfe9a3fdd486a32b238e6b59c52fac76a77c907 Mon Sep 17 00:00:00 2001
From: shirly121 <zxlmillie@163.com>
Date: Mon, 7 Nov 2022 13:57:57 +0800
Subject: [PATCH] [Bug Fix] Avoid throwing exception after processing grpc
 error from executor in compiler (#2182)

* [Bug Fix] avoid throwing exception after processing onError from grpc in compiler

* [Bug Fix] refine codes according to reviews

Co-authored-by: Longbin Lai <longbin.lailb@alibaba-inc.com>
---
 .../graphscope/common/client/RpcBroadcastProcessor.java      | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcBroadcastProcessor.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcBroadcastProcessor.java
index 75e1857ef2bf..6b31baa7f7ae 100644
--- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcBroadcastProcessor.java
+++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcBroadcastProcessor.java
@@ -54,10 +54,9 @@ public void broadcast(PegasusClient.JobRequest request, ResultProcessor processo
                 processor.process(response);
             }
             processor.finish();
-        } catch (Exception e) {
-            logger.error("broadcast exception {}", e);
+        } catch (Throwable e) {
+            logger.error("get result from grpc returns error {}", e);
             processor.error(Status.fromThrowable(e));
-            throw new RuntimeException(e);
         } finally {
             if (iterator != null) {
                 try {