Add logs

Author: sakthivelmanii

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

@@ -337,6 +337,12 @@ public void run() {
    * the buffer and dispatches the {@link CallbackRunnable} when data is ready to be consumed.
    */
   private class ProduceRowsRunnable implements Runnable {
+
+    public ProduceRowsRunnable(StackTraceElement[] stackTrace) {
+      ThreadLocal<StackTraceElement[]> threadLocal = new ThreadLocal<>();
+      threadLocal.set(stackTrace);
+    }
+
     @Override
     public void run() {
       boolean stop = false;
@@ -502,7 +508,7 @@ private void initiateProduceRows() {
       this.state = State.RUNNING;
     }
     produceRowsInitiated = true;
-    this.service.execute(new ProduceRowsRunnable());
+    this.service.execute(new ProduceRowsRunnable(Thread.currentThread().getStackTrace()));
   }
 
   Future<Void> getResult() {

google-cloud-spanner/src/test/java/com/google/cloud/spanner/MockSpannerServiceImpl.java

@@ -652,10 +652,11 @@ private ByteString generateTransactionName(String session, String mutationString
       counter = new AtomicLong();
       transactionCounters.put(session, counter);
     }
+    ThreadLocal<StackTraceElement[]> threadLocal = new ThreadLocal<>();
     transactionToTrace.put(
         session,
         String.format(
-            "%s %s", mutationString, Arrays.toString(Thread.currentThread().getStackTrace())));
+            "%s %s", mutationString, Arrays.toString(threadLocal.get()) + Arrays.toString(Thread.currentThread().getStackTrace())));
     return ByteString.copyFromUtf8(
         String.format("%s/transactions/%d", session, counter.incrementAndGet()));
   }