Skip to content

Commit 46d6e7d

Browse files
fix(spanner): Add logs
1 parent 6225efa commit 46d6e7d

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -468,6 +468,7 @@ public void run() {
468468
// Those result sets will trigger initiateProduceRows() when the first results are received.
469469
// Non-streaming result sets do not trigger this callback, and for those result sets, we
470470
// need to eagerly start the ProduceRowsRunnable.
471+
System.out.printf("Initiate streaming %s\n", state);
471472
if (!initiateStreaming(AsyncResultSetImpl.this)) {
472473
initiateProduceRows();
473474
}

google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1573,6 +1573,7 @@ private void asyncTransactionManager_readAsync(
15731573
context.then(
15741574
(transaction, ignored) -> {
15751575
AsyncResultSet rs = fn.apply(transaction);
1576+
System.out.println("Creating a new Async Result set streaming");
15761577
ApiFuture<Void> fut =
15771578
rs.setCallback(
15781579
queryExecutor,

0 commit comments

Comments
 (0)