Skip to content

Commit

Permalink
Add runner logs
Browse files Browse the repository at this point in the history
  • Loading branch information
sakthivelmanii committed Jan 6, 2025
1 parent 4afff99 commit 4c8d51d
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1224,6 +1224,7 @@ public void executeStreamingSql(
|| !request.getSql().equals(SessionPool.DETERMINE_DIALECT_STATEMENT.getSql())) {
requests.add(request);
}
System.out.println("executeStreamingSql");
Preconditions.checkNotNull(request.getSession());
Session session = getSession(request.getSession());
if (session == null) {
Expand Down Expand Up @@ -1831,6 +1832,7 @@ private ByteString getTransactionId(Session session, TransactionSelector tx) {
transactionId = null;
break;
case BEGIN:
System.out.println("getTransactionId");
transactionId = beginTransaction(session, tx.getBegin(), null, null).getId();
break;
case ID:
Expand Down

0 comments on commit 4c8d51d

Please sign in to comment.