Skip to content

Commit eed112b

Browse files
Suvrat1629kevinrr888
Suvrat1629
and
kevinrr888
authored
Rename TxName to fateOp for clarity (apache#5230) (apache#5336)
* renamed txName and other references to fateOp Renames TxName and similar references to FateOp closes apache#5230 Co-authored-by: Kevin Rathbun <kevinrr888@gmail.com>
1 parent 6452727 commit eed112b

File tree

20 files changed

+71
-71
lines changed

20 files changed

+71
-71
lines changed

‎core/src/main/java/org/apache/accumulo/core/fate/AdminUtil.java

+10-10
Original file line numberDiff line numberDiff line change
@@ -65,20 +65,20 @@ public static class TransactionStatus {
6565
private final FateId fateId;
6666
private final FateInstanceType instanceType;
6767
private final TStatus status;
68-
private final Fate.FateOperation txName;
68+
private final Fate.FateOperation fateOp;
6969
private final List<String> hlocks;
7070
private final List<String> wlocks;
7171
private final String top;
7272
private final long timeCreated;
7373

7474
private TransactionStatus(FateId fateId, FateInstanceType instanceType, TStatus status,
75-
Fate.FateOperation txName, List<String> hlocks, List<String> wlocks, String top,
75+
Fate.FateOperation fateOp, List<String> hlocks, List<String> wlocks, String top,
7676
Long timeCreated) {
7777

7878
this.fateId = fateId;
7979
this.instanceType = instanceType;
8080
this.status = status;
81-
this.txName = txName;
81+
this.fateOp = fateOp;
8282
this.hlocks = Collections.unmodifiableList(hlocks);
8383
this.wlocks = Collections.unmodifiableList(wlocks);
8484
this.top = top;
@@ -105,8 +105,8 @@ public TStatus getStatus() {
105105
/**
106106
* @return The name of the transaction running.
107107
*/
108-
public Fate.FateOperation getTxName() {
109-
return txName;
108+
public Fate.FateOperation getFateOp() {
109+
return fateOp;
110110
}
111111

112112
/**
@@ -353,9 +353,9 @@ public static <T> FateStatus getTransactionStatus(
353353
fateIds.forEach(fateId -> {
354354

355355
ReadOnlyFateTxStore<T> txStore = store.read(fateId);
356-
// tx name will not be set if the tx is not seeded with work (it is NEW)
357-
Fate.FateOperation txName = txStore.getTransactionInfo(Fate.TxInfo.TX_NAME) == null ? null
358-
: ((Fate.FateOperation) txStore.getTransactionInfo(Fate.TxInfo.TX_NAME));
356+
// fate op will not be set if the tx is not seeded with work (it is NEW)
357+
Fate.FateOperation fateOp = txStore.getTransactionInfo(Fate.TxInfo.FATE_OP) == null ? null
358+
: ((Fate.FateOperation) txStore.getTransactionInfo(Fate.TxInfo.FATE_OP));
359359

360360
List<String> hlocks = heldLocks.remove(fateId);
361361

@@ -381,7 +381,7 @@ public static <T> FateStatus getTransactionStatus(
381381

382382
if (includeByStatus(status, statusFilter) && includeByFateId(fateId, fateIdFilter)
383383
&& includeByInstanceType(fateId.getType(), typesFilter)) {
384-
statuses.add(new TransactionStatus(fateId, type, status, txName, hlocks, wlocks, top,
384+
statuses.add(new TransactionStatus(fateId, type, status, fateOp, hlocks, wlocks, top,
385385
timeCreated));
386386
}
387387
});
@@ -418,7 +418,7 @@ public void print(Map<FateInstanceType,ReadOnlyFateStore<T>> readOnlyFateStores,
418418
for (TransactionStatus txStatus : fateStatus.getTransactions()) {
419419
fmt.format(
420420
"%-15s fateId: %s status: %-18s locked: %-15s locking: %-15s op: %-15s created: %s%n",
421-
txStatus.getTxName(), txStatus.getFateId(), txStatus.getStatus(), txStatus.getHeldLocks(),
421+
txStatus.getFateOp(), txStatus.getFateId(), txStatus.getStatus(), txStatus.getHeldLocks(),
422422
txStatus.getWaitingLocks(), txStatus.getTop(), txStatus.getTimeCreatedFormatted());
423423
}
424424
fmt.format(" %s transactions", fateStatus.getTransactions().size());

‎core/src/main/java/org/apache/accumulo/core/fate/Fate.java

+5-5
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public class Fate<T> {
9696
private final ConcurrentLinkedQueue<Integer> idleCountHistory = new ConcurrentLinkedQueue<>();
9797

9898
public enum TxInfo {
99-
TX_NAME, AUTO_CLEAN, EXCEPTION, TX_AGEOFF, RETURN_VALUE
99+
FATE_OP, AUTO_CLEAN, EXCEPTION, TX_AGEOFF, RETURN_VALUE
100100
}
101101

102102
public enum FateOperation {
@@ -538,17 +538,17 @@ public FateId startTransaction() {
538538
return store.create();
539539
}
540540

541-
public void seedTransaction(FateOperation txName, FateKey fateKey, Repo<T> repo,
541+
public void seedTransaction(FateOperation fateOp, FateKey fateKey, Repo<T> repo,
542542
boolean autoCleanUp) {
543-
store.seedTransaction(txName, fateKey, repo, autoCleanUp);
543+
store.seedTransaction(fateOp, fateKey, repo, autoCleanUp);
544544
}
545545

546546
// start work in the transaction.. it is safe to call this
547547
// multiple times for a transaction... but it will only seed once
548-
public void seedTransaction(FateOperation txName, FateId fateId, Repo<T> repo,
548+
public void seedTransaction(FateOperation fateOp, FateId fateId, Repo<T> repo,
549549
boolean autoCleanUp, String goalMessage) {
550550
log.info("Seeding {} {}", fateId, goalMessage);
551-
store.seedTransaction(txName, fateId, repo, autoCleanUp);
551+
store.seedTransaction(fateOp, fateId, repo, autoCleanUp);
552552
}
553553

554554
// check on the transaction

‎core/src/main/java/org/apache/accumulo/core/fate/FateStore.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public interface FateStore<T> extends ReadOnlyFateStore<T> {
5454
* fateKey. If seeded, sets the following data for the fateId in the store.
5555
*
5656
* <ul>
57-
* <li>Set the tx name</li>
57+
* <li>Set the fate op</li>
5858
* <li>Set the status to SUBMITTED</li>
5959
* <li>Set the fate key</li>
6060
* <li>Sets autocleanup only if true</li>
@@ -66,15 +66,15 @@ public interface FateStore<T> extends ReadOnlyFateStore<T> {
6666
* empty optional otherwise. If there was a failure this could return an empty optional
6767
* when it actually succeeded.
6868
*/
69-
Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey, Repo<T> repo,
69+
Optional<FateId> seedTransaction(Fate.FateOperation fateOp, FateKey fateKey, Repo<T> repo,
7070
boolean autoCleanUp);
7171

7272
/**
7373
* Seeds a transaction with the given repo if its current status is NEW and it is currently
7474
* unreserved. If seeded, sets the following data for the fateId in the store.
7575
*
7676
* <ul>
77-
* <li>Set the tx name</li>
77+
* <li>Set the fate op</li>
7878
* <li>Set the status to SUBMITTED</li>
7979
* <li>Sets autocleanup only if true</li>
8080
* <li>Sets the creation time</li>
@@ -84,7 +84,7 @@ Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey, Rep
8484
* failures. When there are no failures returns true if seeded and false otherwise. If
8585
* there was a failure this could return false when it actually succeeded.
8686
*/
87-
boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<T> repo,
87+
boolean seedTransaction(Fate.FateOperation fateOp, FateId fateId, Repo<T> repo,
8888
boolean autoCleanUp);
8989

9090
/**

‎core/src/main/java/org/apache/accumulo/core/fate/user/FateMutator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public interface FateMutator<T> {
7575
*/
7676
FateMutator<T> putUnreserveTx(FateStore.FateReservation reservation);
7777

78-
FateMutator<T> putName(byte[] data);
78+
FateMutator<T> putFateOp(byte[] data);
7979

8080
FateMutator<T> putAutoClean(byte[] data);
8181

‎core/src/main/java/org/apache/accumulo/core/fate/user/FateMutatorImpl.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -129,8 +129,8 @@ public FateMutator<T> putUnreserveTx(FateStore.FateReservation reservation) {
129129
}
130130

131131
@Override
132-
public FateMutator<T> putName(byte[] data) {
133-
TxInfoColumnFamily.TX_NAME_COLUMN.put(mutation, new Value(data));
132+
public FateMutator<T> putFateOp(byte[] data) {
133+
TxInfoColumnFamily.FATE_OP_COLUMN.put(mutation, new Value(data));
134134
return this;
135135
}
136136

@@ -161,8 +161,8 @@ public FateMutator<T> putAgeOff(byte[] data) {
161161
@Override
162162
public FateMutator<T> putTxInfo(TxInfo txInfo, byte[] data) {
163163
switch (txInfo) {
164-
case TX_NAME:
165-
putName(data);
164+
case FATE_OP:
165+
putFateOp(data);
166166
break;
167167
case AUTO_CLEAN:
168168
putAutoClean(data);

‎core/src/main/java/org/apache/accumulo/core/fate/user/UserFateStore.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -133,33 +133,33 @@ public FateId getFateId() {
133133
}
134134

135135
@Override
136-
public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey, Repo<T> repo,
136+
public Optional<FateId> seedTransaction(Fate.FateOperation fateOp, FateKey fateKey, Repo<T> repo,
137137
boolean autoCleanUp) {
138138
final var fateId = fateIdGenerator.fromTypeAndKey(type(), fateKey);
139139
Supplier<FateMutator<T>> mutatorFactory = () -> newMutator(fateId).requireAbsent()
140140
.putKey(fateKey).putCreateTime(System.currentTimeMillis());
141-
if (seedTransaction(mutatorFactory, fateKey + " " + fateId, txName, repo, autoCleanUp)) {
141+
if (seedTransaction(mutatorFactory, fateKey + " " + fateId, fateOp, repo, autoCleanUp)) {
142142
return Optional.of(fateId);
143143
} else {
144144
return Optional.empty();
145145
}
146146
}
147147

148148
@Override
149-
public boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<T> repo,
149+
public boolean seedTransaction(Fate.FateOperation fateOp, FateId fateId, Repo<T> repo,
150150
boolean autoCleanUp) {
151151
Supplier<FateMutator<T>> mutatorFactory =
152152
() -> newMutator(fateId).requireStatus(TStatus.NEW).requireUnreserved().requireAbsentKey();
153-
return seedTransaction(mutatorFactory, fateId.canonical(), txName, repo, autoCleanUp);
153+
return seedTransaction(mutatorFactory, fateId.canonical(), fateOp, repo, autoCleanUp);
154154
}
155155

156156
private boolean seedTransaction(Supplier<FateMutator<T>> mutatorFactory, String logId,
157-
Fate.FateOperation txName, Repo<T> repo, boolean autoCleanUp) {
157+
Fate.FateOperation fateOp, Repo<T> repo, boolean autoCleanUp) {
158158
int maxAttempts = 5;
159159
for (int attempt = 0; attempt < maxAttempts; attempt++) {
160160
var mutator = mutatorFactory.get();
161161
mutator =
162-
mutator.putName(serializeTxInfo(txName)).putRepo(1, repo).putStatus(TStatus.SUBMITTED);
162+
mutator.putFateOp(serializeTxInfo(fateOp)).putRepo(1, repo).putStatus(TStatus.SUBMITTED);
163163
if (autoCleanUp) {
164164
mutator = mutator.putAutoClean(serializeTxInfo(autoCleanUp));
165165
}
@@ -420,8 +420,8 @@ public Serializable getTransactionInfo(TxInfo txInfo) {
420420

421421
final ColumnFQ cq;
422422
switch (txInfo) {
423-
case TX_NAME:
424-
cq = TxInfoColumnFamily.TX_NAME_COLUMN;
423+
case FATE_OP:
424+
cq = TxInfoColumnFamily.FATE_OP_COLUMN;
425425
break;
426426
case AUTO_CLEAN:
427427
cq = TxInfoColumnFamily.AUTO_CLEAN_COLUMN;

‎core/src/main/java/org/apache/accumulo/core/fate/user/schema/FateSchema.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ public static class TxInfoColumnFamily {
4444
public static final String STR_NAME = "txinfo";
4545
public static final Text NAME = new Text(STR_NAME);
4646

47-
public static final String TX_NAME = "txname";
48-
public static final ColumnFQ TX_NAME_COLUMN = new ColumnFQ(NAME, new Text(TX_NAME));
47+
public static final String FATE_OP = "fateop";
48+
public static final ColumnFQ FATE_OP_COLUMN = new ColumnFQ(NAME, new Text(FATE_OP));
4949

5050
public static final String AUTO_CLEAN = "autoclean";
5151
public static final ColumnFQ AUTO_CLEAN_COLUMN = new ColumnFQ(NAME, new Text(AUTO_CLEAN));

‎core/src/main/java/org/apache/accumulo/core/fate/zookeeper/MetaFateStore.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -181,11 +181,11 @@ private Optional<FateTxStore<T>> createAndReserve(FateKey fateKey) {
181181
}
182182

183183
@Override
184-
public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey, Repo<T> repo,
184+
public Optional<FateId> seedTransaction(Fate.FateOperation fateOp, FateKey fateKey, Repo<T> repo,
185185
boolean autoCleanUp) {
186186
return createAndReserve(fateKey).map(txStore -> {
187187
try {
188-
seedTransaction(txName, repo, autoCleanUp, txStore);
188+
seedTransaction(fateOp, repo, autoCleanUp, txStore);
189189
return txStore.getID();
190190
} finally {
191191
txStore.unreserve(Duration.ZERO);
@@ -194,12 +194,12 @@ public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateK
194194
}
195195

196196
@Override
197-
public boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<T> repo,
197+
public boolean seedTransaction(Fate.FateOperation fateOp, FateId fateId, Repo<T> repo,
198198
boolean autoCleanUp) {
199199
return tryReserve(fateId).map(txStore -> {
200200
try {
201201
if (txStore.getStatus() == NEW) {
202-
seedTransaction(txName, repo, autoCleanUp, txStore);
202+
seedTransaction(fateOp, repo, autoCleanUp, txStore);
203203
return true;
204204
}
205205
return false;
@@ -209,7 +209,7 @@ public boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<T>
209209
}).orElse(false);
210210
}
211211

212-
private void seedTransaction(Fate.FateOperation txName, Repo<T> repo, boolean autoCleanUp,
212+
private void seedTransaction(Fate.FateOperation fateOp, Repo<T> repo, boolean autoCleanUp,
213213
FateTxStore<T> txStore) {
214214
if (txStore.top() == null) {
215215
try {
@@ -223,7 +223,7 @@ private void seedTransaction(Fate.FateOperation txName, Repo<T> repo, boolean au
223223
if (autoCleanUp) {
224224
txStore.setTransactionInfo(TxInfo.AUTO_CLEAN, autoCleanUp);
225225
}
226-
txStore.setTransactionInfo(TxInfo.TX_NAME, txName);
226+
txStore.setTransactionInfo(TxInfo.FATE_OP, fateOp);
227227
txStore.setStatus(SUBMITTED);
228228
}
229229

‎core/src/main/java/org/apache/accumulo/core/logging/FateLogger.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,9 @@ public FateId create() {
150150
}
151151

152152
@Override
153-
public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey,
153+
public Optional<FateId> seedTransaction(Fate.FateOperation fateOp, FateKey fateKey,
154154
Repo<T> repo, boolean autoCleanUp) {
155-
var optional = store.seedTransaction(txName, fateKey, repo, autoCleanUp);
155+
var optional = store.seedTransaction(fateOp, fateKey, repo, autoCleanUp);
156156
if (storeLog.isTraceEnabled()) {
157157
optional.ifPresentOrElse(fateId -> {
158158
storeLog.trace("{} seeded {} {} {}", fateId, fateKey, toLogString.apply(repo),
@@ -166,9 +166,9 @@ public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateK
166166
}
167167

168168
@Override
169-
public boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<T> repo,
169+
public boolean seedTransaction(Fate.FateOperation fateOp, FateId fateId, Repo<T> repo,
170170
boolean autoCleanUp) {
171-
boolean seeded = store.seedTransaction(txName, fateId, repo, autoCleanUp);
171+
boolean seeded = store.seedTransaction(fateOp, fateId, repo, autoCleanUp);
172172
if (storeLog.isTraceEnabled()) {
173173
storeLog.trace("{} {} {} {}", fateId, seeded ? "seeded" : "unable to seed",
174174
toLogString.apply(repo), autoCleanUp);

‎core/src/test/java/org/apache/accumulo/core/fate/TestStore.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -53,13 +53,13 @@ public FateId create() {
5353
}
5454

5555
@Override
56-
public Optional<FateId> seedTransaction(Fate.FateOperation txName, FateKey fateKey,
56+
public Optional<FateId> seedTransaction(Fate.FateOperation fateOp, FateKey fateKey,
5757
Repo<String> repo, boolean autoCleanUp) {
5858
return Optional.empty();
5959
}
6060

6161
@Override
62-
public boolean seedTransaction(Fate.FateOperation txName, FateId fateId, Repo<String> repo,
62+
public boolean seedTransaction(Fate.FateOperation fateOp, FateId fateId, Repo<String> repo,
6363
boolean autoCleanUp) {
6464
return false;
6565
}

‎server/base/src/main/java/org/apache/accumulo/server/util/fateCommand/FateSummaryReport.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public void gatherTxnStatus(AdminUtil.TransactionStatus txnStatus) {
8888
}
8989
String top = txnStatus.getTop();
9090
stepCounts.merge(Objects.requireNonNullElse(top, "?"), 1, Integer::sum);
91-
Fate.FateOperation runningRepo = txnStatus.getTxName();
91+
Fate.FateOperation runningRepo = txnStatus.getFateOp();
9292

9393
cmdCounts.merge(runningRepo == null ? "?" : runningRepo.name(), 1, Integer::sum);
9494

‎server/base/src/main/java/org/apache/accumulo/server/util/fateCommand/FateTxnDetails.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ public class FateTxnDetails implements Comparable<FateTxnDetails> {
3333

3434
private long running;
3535
private String status = "?";
36-
private String txName = "?";
36+
private String fateOp = "?";
3737
private String step = "?";
3838
private String fateId = "?";
3939
private List<String> locksHeld = List.of();
@@ -73,8 +73,8 @@ public FateTxnDetails(final long reportTime, final AdminUtil.TransactionStatus t
7373
if (txnStatus.getTop() != null) {
7474
step = txnStatus.getTop();
7575
}
76-
if (txnStatus.getTxName() != null) {
77-
txName = txnStatus.getTxName().name();
76+
if (txnStatus.getFateOp() != null) {
77+
fateOp = txnStatus.getFateOp().name();
7878
}
7979
if (txnStatus.getFateId() != null) {
8080
fateId = txnStatus.getFateId().canonical();
@@ -103,8 +103,8 @@ public long getRunning() {
103103
return running;
104104
}
105105

106-
public String getTxName() {
107-
return txName;
106+
public String getFateOp() {
107+
return fateOp;
108108
}
109109

110110
public String getStep() {
@@ -167,7 +167,7 @@ public String toString() {
167167
String hms = String.format("%d:%02d:%02d", elapsed.toHours(), elapsed.toMinutesPart(),
168168
elapsed.toSecondsPart());
169169

170-
return hms + "\t" + fateId + "\t" + status + "\t" + txName + "\t" + step + "\theld:"
170+
return hms + "\t" + fateId + "\t" + status + "\t" + fateOp + "\t" + step + "\theld:"
171171
+ locksHeld.toString() + "\twaiting:" + locksWaiting.toString();
172172
}
173173

‎server/base/src/test/java/org/apache/accumulo/server/util/fateCommand/SummaryReportTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public void noTablenameReport() {
7373
expect(status1.getTimeCreated()).andReturn(now - TimeUnit.DAYS.toMillis(1)).anyTimes();
7474
expect(status1.getStatus()).andReturn(ReadOnlyFateStore.TStatus.IN_PROGRESS).anyTimes();
7575
expect(status1.getTop()).andReturn(null).anyTimes();
76-
expect(status1.getTxName()).andReturn(null).anyTimes();
76+
expect(status1.getFateOp()).andReturn(null).anyTimes();
7777
expect(status1.getFateId()).andReturn(FateId.from("FATE:USER:" + UUID.randomUUID())).anyTimes();
7878
expect(status1.getHeldLocks()).andReturn(List.of()).anyTimes();
7979
expect(status1.getWaitingLocks()).andReturn(List.of()).anyTimes();

‎server/base/src/test/java/org/apache/accumulo/server/util/fateCommand/TxnDetailsTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ void orderingByDuration() {
5858
expect(status1.getTimeCreated()).andReturn(now - TimeUnit.DAYS.toMillis(1)).anyTimes();
5959
expect(status1.getStatus()).andReturn(ReadOnlyFateStore.TStatus.IN_PROGRESS).anyTimes();
6060
expect(status1.getTop()).andReturn("step1").anyTimes();
61-
expect(status1.getTxName()).andReturn(Fate.FateOperation.TABLE_CREATE).anyTimes();
61+
expect(status1.getFateOp()).andReturn(Fate.FateOperation.TABLE_CREATE).anyTimes();
6262
expect(status1.getFateId()).andReturn(FateId.from("FATE:USER:" + uuid1)).anyTimes();
6363
expect(status1.getHeldLocks()).andReturn(List.of()).anyTimes();
6464
expect(status1.getWaitingLocks()).andReturn(List.of()).anyTimes();
@@ -67,7 +67,7 @@ void orderingByDuration() {
6767
expect(status2.getTimeCreated()).andReturn(now - TimeUnit.DAYS.toMillis(7)).anyTimes();
6868
expect(status2.getStatus()).andReturn(ReadOnlyFateStore.TStatus.IN_PROGRESS).anyTimes();
6969
expect(status2.getTop()).andReturn("step2").anyTimes();
70-
expect(status2.getTxName()).andReturn(Fate.FateOperation.TABLE_DELETE).anyTimes();
70+
expect(status2.getFateOp()).andReturn(Fate.FateOperation.TABLE_DELETE).anyTimes();
7171
expect(status2.getFateId()).andReturn(FateId.from("FATE:USER:" + uuid2)).anyTimes();
7272
expect(status2.getHeldLocks()).andReturn(List.of()).anyTimes();
7373
expect(status2.getWaitingLocks()).andReturn(List.of()).anyTimes();
@@ -101,7 +101,7 @@ public void lockTest() {
101101
expect(status1.getTimeCreated()).andReturn(now - TimeUnit.DAYS.toMillis(1)).anyTimes();
102102
expect(status1.getStatus()).andReturn(ReadOnlyFateStore.TStatus.IN_PROGRESS).anyTimes();
103103
expect(status1.getTop()).andReturn("step1").anyTimes();
104-
expect(status1.getTxName()).andReturn(Fate.FateOperation.TABLE_COMPACT).anyTimes();
104+
expect(status1.getFateOp()).andReturn(Fate.FateOperation.TABLE_COMPACT).anyTimes();
105105
expect(status1.getFateId()).andReturn(FateId.from("FATE:USER:" + UUID.randomUUID())).anyTimes();
106106
// incomplete lock info (W unknown ns id, no table))
107107
expect(status1.getHeldLocks()).andReturn(List.of("R:1", "R:2", "W:a")).anyTimes();

0 commit comments

Comments
 (0)