Skip to content

Commit 5580949

Browse files
Add logs
1 parent dcfff9b commit 5580949

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -490,8 +490,7 @@ public ApiFuture<Void> setCallback(Executor exec, ReadyCallback cb) {
490490
// Start to fetch data and buffer these.
491491
this.result = SettableApiFuture.create();
492492
this.state = State.STREAMING_INITIALIZED;
493-
// this.service.execute(new InitiateStreamingRunnable());
494-
initiateProduceRows();
493+
this.service.execute(new InitiateStreamingRunnable());
495494
this.executor = MoreExecutors.newSequentialExecutor(Preconditions.checkNotNull(exec));
496495
this.callback = Preconditions.checkNotNull(cb);
497496
pausedLatch.countDown();

0 commit comments

Comments
 (0)