Skip to content

Commit 07cceae

Browse files
committed
IGNITE-27702 Minor changes
1 parent 693e3d5 commit 07cceae

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/handlers/FinishTxCommandHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ private static List<EnlistedPartitionGroup> fromPartitionMessages(List<EnlistedP
135135
}
136136

137137
private static void logTxStateStorageCasFail(UUID txId, TxMeta txMetaBeforeCas, TxMeta txMetaToSet) {
138-
String errorMsg = format("Finish command skipped, transaction txId = {} transaction state is already set,"
138+
String errorMsg = format("Finish command skipped, transaction txId = {}, because transaction state is already set,"
139139
+ " existing state = {}, state to set = {}",
140140
txId,
141141
txMetaBeforeCas,

modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/handlers/TxFinishReplicaRequestHandlerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ void finishReturnsMismatchingOutcomeWhenCommitRequestedButAlreadyAborted() {
109109
HybridTimestamp commitTimestamp = new HybridTimestamp(123, 456);
110110

111111
when(schemaSyncService.waitForMetadataCompleteness(any())).thenReturn(completedFuture(null));
112-
when(txStatePartitionStorage.get(txId)).thenReturn(new TxMeta(TxState.ABORTED, List.of(), commitTimestamp));
112+
when(txStatePartitionStorage.get(txId)).thenReturn(new TxMeta(TxState.ABORTED, List.of(), null));
113113

114114
TxFinishReplicaRequest request = txMessagesFactory.txFinishReplicaRequest()
115115
.commitTimestamp(commitTimestamp)

0 commit comments

Comments
 (0)