add more logs

googleapis · Jan 6, 2025 · 6e25d40 · 6e25d40
1 parent ba27bfa
commit 6e25d40
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/GrpcResultSet.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/GrpcResultSet.java
@@ -78,7 +78,7 @@ public boolean next() throws SpannerException {
     if (error != null) {
       throw newSpannerException(error);
     }
-    System.out.println("GrpcResultSet next");
+    System.out.println("GrpcResultSet next " + iterator);
     try {
       if (currRow == null) {
         metadata = iterator.getMetadata();
@@ -129,6 +129,7 @@ public ResultSetMetadata getMetadata() {
   @Override
   @InternalApi
   public boolean initiateStreaming(AsyncResultSet.StreamMessageListener streamMessageListener) {
+    System.out.println("Iterator " + iterator);
     return iterator.initiateStreaming(streamMessageListener);
   }
 

diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/ResumableStreamIterator.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/ResumableStreamIterator.java
@@ -318,7 +318,7 @@ && prepareIteratorForRetryOnDifferentGrpcChannel()) {
   }
 
   private void startGrpcStreaming() {
-    System.out.println("Starting Stream");
+    System.out.println("Starting Stream " + stream + " " + streamMessageListener);
     if (stream == null) {
       span.addAnnotation(
           "Starting/Resuming stream",
@@ -327,7 +327,7 @@ private void startGrpcStreaming() {
       try (IScope scope = tracer.withSpan(span)) {
         // When start a new stream set the Span as current to make the gRPC Span a child of
         // this Span.
-        System.out.println("Creating Stream");
+        System.out.println("Creating Stream " + stream + " " + streamMessageListener);
         stream = checkNotNull(startStream(resumeToken, streamMessageListener));
       }
     }