diff --git a/bvm/ballerina-runtime/src/main/java/io/ballerina/runtime/transactions/TransactionResourceManager.java b/bvm/ballerina-runtime/src/main/java/io/ballerina/runtime/transactions/TransactionResourceManager.java index 00cde49ef17a..83b0cf9d6b1e 100644 --- a/bvm/ballerina-runtime/src/main/java/io/ballerina/runtime/transactions/TransactionResourceManager.java +++ b/bvm/ballerina-runtime/src/main/java/io/ballerina/runtime/transactions/TransactionResourceManager.java @@ -589,11 +589,11 @@ private void removeContextsFromRegistry(String transactionCombinedId, String gTr } private String generateCombinedTransactionId(String transactionId, String transactionBlockId) { - String compoundId = transactionId + ":" + transactionBlockId; if (transactionBlockId.contains("_")) { - return compoundId; + // remove the strand id from the transaction block id + return transactionBlockId.split("_")[0]; } - return compoundId + "_" + Scheduler.getStrand().getId(); + return transactionId + ":" + transactionBlockId; } public void notifyResourceFailure(String gTransactionId) {