Skip to content

Commit

Permalink
chore: generate libraries at Mon Jan 6 14:26:28 UTC 2025
Browse files Browse the repository at this point in the history
  • Loading branch information
cloud-java-bot committed Jan 6, 2025
1 parent 7a96270 commit 816c5ee
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -470,14 +470,14 @@ public void run() {
// Non-streaming result sets do not trigger this callback, and for those result sets, we
// need to eagerly start the ProduceRowsRunnable.
synchronized (monitor) {
// if (state == State.STREAMING_IN_PROGRESS
// || state == State.RUNNING
// || state == State.CONSUMING) {
// return;
// }
// if (state == State.STREAMING_INITIALIZED) {
// state = State.STREAMING_IN_PROGRESS;
// }
// if (state == State.STREAMING_IN_PROGRESS
// || state == State.RUNNING
// || state == State.CONSUMING) {
// return;
// }
// if (state == State.STREAMING_INITIALIZED) {
// state = State.STREAMING_IN_PROGRESS;
// }
if (!initiateStreaming(AsyncResultSetImpl.this)) {
initiateProduceRows();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2000,7 +2000,8 @@ private void ensureMostRecentTransaction(Session session, ByteString transaction
if (index > -1) {
long id = Long.parseLong(transactionId.toStringUtf8().substring(index + 1));
if (id != counter.get()) {
System.out.printf("Session ID %s TransactionId %s\n", session.getName(), transactionId.toStringUtf8());
System.out.printf(
"Session ID %s TransactionId %s\n", session.getName(), transactionId.toStringUtf8());
throw Status.FAILED_PRECONDITION
.withDescription(
String.format(
Expand Down

0 comments on commit 816c5ee

Please sign in to comment.