[Bug Fix] Avoid throwing exception after processing grpc error from e…

…xecutor 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>
alibaba · Nov 7, 2022 · 7cfe9a3 · 7cfe9a3
1 parent abdd5c9
commit 7cfe9a3
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...ne/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcBroadcastProcessor.java b/...ne/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 {