diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java index b357b5eabd..67058600d5 100644 --- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java +++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java @@ -490,7 +490,7 @@ public ApiFuture setCallback(Executor exec, ReadyCallback cb) { this.result = SettableApiFuture.create(); this.state = State.STREAMING_INITIALIZED; this.service.execute(new InitiateStreamingRunnable()); -// initiateProduceRows(); + // initiateProduceRows(); this.executor = MoreExecutors.newSequentialExecutor(Preconditions.checkNotNull(exec)); this.callback = Preconditions.checkNotNull(cb); pausedLatch.countDown(); diff --git a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java index 85ae743437..b52605d9c8 100644 --- a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java +++ b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java @@ -1593,7 +1593,7 @@ private void asyncTransactionManager_readAsync( AsyncTransactionStep count = context.then( (transaction, ignored) -> { - try(AsyncResultSet rs = fn.apply(transaction)) { + try (AsyncResultSet rs = fn.apply(transaction)) { ApiFuture fut = rs.setCallback( queryExecutor,