[BEAM-8008] show error message from expansion service in Java Externa…

…l transform
grtheod · Aug 22, 2019 · 744fe67 · 744fe67
1 parent eddaf92
commit 744fe67
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...e-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java b/...e-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java
@@ -40,6 +40,7 @@
 import org.apache.beam.sdk.values.TupleTag;
 import org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.ByteString;
 import org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ManagedChannelBuilder;
+import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Strings;
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap;
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables;
 
@@ -186,6 +187,11 @@ public OutputT expand(PInput input) {
       ExpansionApi.ExpansionResponse response =
           DEFAULT.getExpansionServiceClient(endpoint).expand(request);
 
+      if (!Strings.isNullOrEmpty(response.getError())) {
+        throw new RuntimeException(
+            String.format("expansion service error: %s", response.getError()));
+      }
+
       expandedComponents = response.getComponents();
       expandedTransform = response.getTransform();