Skip to content

Commit 34b007c

Browse files
Add runner logs
1 parent 86b37c4 commit 34b007c

File tree

2 files changed

+14
-14
lines changed

2 files changed

+14
-14
lines changed

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

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -470,19 +470,19 @@ public void run() {
470470
// Those result sets will trigger initiateProduceRows() when the first results are received.
471471
// Non-streaming result sets do not trigger this callback, and for those result sets, we
472472
// need to eagerly start the ProduceRowsRunnable.
473-
// synchronized (monitor) {
474-
// if (state == State.STREAMING_IN_PROGRESS
475-
// || state == State.RUNNING
476-
// || state == State.CONSUMING) {
477-
// return;
478-
// }
479-
// if (state == State.STREAMING_INITIALIZED) {
480-
// state = State.STREAMING_IN_PROGRESS;
481-
// }
482-
if (!initiateStreaming(AsyncResultSetImpl.this)) {
483-
initiateProduceRows();
484-
}
485-
// }
473+
// synchronized (monitor) {
474+
// if (state == State.STREAMING_IN_PROGRESS
475+
// || state == State.RUNNING
476+
// || state == State.CONSUMING) {
477+
// return;
478+
// }
479+
// if (state == State.STREAMING_INITIALIZED) {
480+
// state = State.STREAMING_IN_PROGRESS;
481+
// }
482+
if (!initiateStreaming(AsyncResultSetImpl.this)) {
483+
initiateProduceRows();
484+
}
485+
// }
486486
} catch (Throwable exception) {
487487
executionException = SpannerExceptionFactory.asSpannerException(exception);
488488
initiateProduceRows();

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ public void onCompleted() {
165165

166166
@Override
167167
public void onError(SpannerException e) {
168-
System.out.println("Error " + e.getMessage() + " " + e.getErrorCode());
168+
System.out.println("Error " + e.getMessage() + " " + e.getErrorCode());
169169
if (statement != null) {
170170
if (logger.isLoggable(Level.FINEST)) {
171171
// Include parameter values if logging level is set to FINEST or higher.

0 commit comments

Comments
 (0)