Skip to content

Commit f14bfab

Browse files
authored
Use Position instead of OFFSET into SKIP_ADMIN_MESSAGE. (#2279)
Previously we added position into the admin tool arguments, but we forgot to replace the position with offset into the SKIP_ADMIN_MESSAGE, this makes SKIP_ADMIN_MESSAGE with position usage is not right. Solution: Replace Offset with Position
1 parent 71507d0 commit f14bfab

File tree

1 file changed

+2
-2
lines changed
  • clients/venice-admin-tool/src/main/java/com/linkedin/venice

1 file changed

+2
-2
lines changed

clients/venice-admin-tool/src/main/java/com/linkedin/venice/Command.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,6 @@
9999
import static com.linkedin.venice.Arg.NEARLINE_PRODUCER_COUNT_PER_WRITER;
100100
import static com.linkedin.venice.Arg.NON_INTERACTIVE;
101101
import static com.linkedin.venice.Arg.NUM_VERSIONS_TO_PRESERVE;
102-
import static com.linkedin.venice.Arg.OFFSET;
103102
import static com.linkedin.venice.Arg.OUTFILE;
104103
import static com.linkedin.venice.Arg.OWNER;
105104
import static com.linkedin.venice.Arg.PARENT_DIRECTORY;
@@ -108,6 +107,7 @@
108107
import static com.linkedin.venice.Arg.PARTITIONER_PARAMS;
109108
import static com.linkedin.venice.Arg.PARTITION_COUNT;
110109
import static com.linkedin.venice.Arg.PARTITION_DETAIL_ENABLED;
110+
import static com.linkedin.venice.Arg.POSITION;
111111
import static com.linkedin.venice.Arg.PRINCIPAL;
112112
import static com.linkedin.venice.Arg.PROGRESS_INTERVAL;
113113
import static com.linkedin.venice.Arg.PUSH_ID;
@@ -225,7 +225,7 @@ public enum Command {
225225
), KILL_JOB("kill-job", "Kill a running push job", new Arg[] { URL, STORE, VERSION }, new Arg[] { CLUSTER }),
226226
SKIP_ADMIN_MESSAGE(
227227
"skip-admin-message", "Skip an admin message", new Arg[] { URL, CLUSTER },
228-
new Arg[] { SKIP_DIV, OFFSET, EXECUTION_ID }
228+
new Arg[] { SKIP_DIV, POSITION, EXECUTION_ID }
229229
),
230230
NEW_STORE(
231231
"new-store", "", new Arg[] { URL, CLUSTER, STORE, KEY_SCHEMA, VALUE_SCHEMA }, new Arg[] { OWNER, VSON_STORE }

0 commit comments

Comments
 (0)