Added standard logging when exception is thrown (#17717)

Updated BatchSpannerRead.java with standard logging for exception.
apache · May 26, 2022 · 7c92e8c · 7c92e8c
1 parent ff39fcb
commit 7c92e8c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...gle-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/BatchSpannerRead.java b/...gle-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/BatchSpannerRead.java
@@ -41,6 +41,8 @@
 import org.apache.beam.sdk.values.PCollectionView;
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.annotations.VisibleForTesting;
 import org.checkerframework.checker.nullness.qual.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * This transform reads from Cloud Spanner using the {@link com.google.cloud.spanner.BatchClient}.
@@ -52,6 +54,7 @@
 })
 abstract class BatchSpannerRead
     extends PTransform<PCollection<ReadOperation>, PCollection<Struct>> {
+  private static final Logger LOG = LoggerFactory.getLogger(BatchSpannerRead.class);
 
   public static BatchSpannerRead create(
       SpannerConfig spannerConfig,
@@ -228,6 +231,7 @@ public void processElement(ProcessContext c) throws Exception {
         }
       } catch (SpannerException e) {
         serviceCallMetric.call(e.getErrorCode().getGrpcStatusCode().toString());
+        LOG.error("Error while processing element", e);
         throw (e);
       }
       serviceCallMetric.call("ok");