Skip to content

Commit 5edd199

Browse files
authored
[minor][hotfix] Clean unused code for schema operator&coordinator
This closes #3958
1 parent 1ac12c3 commit 5edd199

File tree

2 files changed

+0
-16
lines changed

2 files changed

+0
-16
lines changed

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java

-9
Original file line numberDiff line numberDiff line change
@@ -463,15 +463,6 @@ private boolean shouldIgnoreException(Throwable throwable) {
463463
&& (SchemaChangeBehavior.TRY_EVOLVE.equals(behavior));
464464
}
465465

466-
/**
467-
* {@code IDLE}: Initial idling state, ready for requests. <br>
468-
* {@code APPLYING}: When schema change application finishes (successfully or with exceptions)
469-
*/
470-
private enum RequestStatus {
471-
IDLE,
472-
APPLYING
473-
}
474-
475466
/**
476467
* Before Flink CDC 3.3, we store routing rules into {@link SchemaCoordinator}'s state, which
477468
* turns out to be unnecessary since data stream topology might change after stateful restarts,

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java

-7
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,6 @@
5151

5252
import java.io.Serializable;
5353
import java.time.Duration;
54-
import java.time.Instant;
5554
import java.util.HashMap;
5655
import java.util.List;
5756
import java.util.Map;
@@ -242,12 +241,6 @@ RESPONSE sendRequestToCoordinator(REQUEST request) {
242241
}
243242
}
244243

245-
/** Visible for mocking in test cases. */
246-
@VisibleForTesting
247-
protected int getCurrentTimestamp() {
248-
return (int) Instant.now().getEpochSecond();
249-
}
250-
251244
@VisibleForTesting
252245
public void registerInitialSchema(TableId tableId, Schema schema) {
253246
originalSchemaMap.put(tableId, schema);

0 commit comments

Comments
 (0)