@@ -645,13 +645,13 @@ private String generateSessionName(String database) {
645645 return String .format ("%s/sessions/%s" , database , UUID .randomUUID ().toString ());
646646 }
647647
648- private ByteString generateTransactionName (String session ) {
648+ private ByteString generateTransactionName (String session , com . google . spanner . v1 . Mutation mutation ) {
649649 AtomicLong counter = transactionCounters .get (session );
650650 if (counter == null ) {
651651 counter = new AtomicLong ();
652652 transactionCounters .put (session , counter );
653653 }
654- transactionToTrace .put (session , Arrays .toString (Thread .currentThread ().getStackTrace ()));
654+ transactionToTrace .put (session , String . format ( "%s %s" , mutation . toString (), Arrays .toString (Thread .currentThread ().getStackTrace () )));
655655 return ByteString .copyFromUtf8 (
656656 String .format ("%s/transactions/%d" , session , counter .incrementAndGet ()));
657657 }
@@ -1910,7 +1910,7 @@ public void beginTransaction(
19101910
19111911 private Transaction beginTransaction (
19121912 Session session , TransactionOptions options , com .google .spanner .v1 .Mutation mutationKey ) {
1913- ByteString transactionId = generateTransactionName (session .getName ());
1913+ ByteString transactionId = generateTransactionName (session .getName (), mutationKey );
19141914 Transaction .Builder builder = Transaction .newBuilder ().setId (transactionId );
19151915 if (options != null && options .getModeCase () == ModeCase .READ_ONLY ) {
19161916 setReadTimestamp (options , builder );
0 commit comments