Add log about num of stream

apache · Feb 26, 2024 · 8c6eb5d · 8c6eb5d
1 parent 015541f
commit 8c6eb5d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java b/...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;