From 8c6eb5db5b5ec116ddcc6e1d91a84fcc02d0c825 Mon Sep 17 00:00:00 2001
From: Yi Hu <yathu@google.com>
Date: Thu, 9 Nov 2023 13:57:48 -0500
Subject: [PATCH] Add log about num of stream

---
 .../beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java
index 1739d7e93952..fd41000ca5b9 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java
@@ -167,8 +167,11 @@ public List<BigQueryStorageStreamSource<T>> split(
     }
 
     if (readSession.getStreamsList().isEmpty()) {
-      // The underlying table is empty or all rows have been pruned.
+      LOG.info(
+          "Returned stream list is empty. The underlying table is empty or all rows have been pruned.");
       return ImmutableList.of();
+    } else {
+      LOG.info("Read session returned {} streams", readSession.getStreamsList().size());
     }
 
     Schema sessionSchema;