[FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics#3619

Merged

ruanhang1993 merged 38 commits intoapache:masterfrom

liuxiao2shf:cdc_base_support_metrics_36315

Dec 6, 2024

Commits on Sep 23, 2024

[FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics
molin.lxd
committed

Commits on Oct 8, 2024

[FLINK-36315][cdc-base]Fix code style issues
molin.lxd
committed
[FLINK-36315][cdc-base]add enterStreamReading while isNewlyAddedAssigningFinished
molin.lxd
committed

Commits on Oct 9, 2024

[FLINK-36315][cdc-base]remove unused variable currentReadTimestampMs
molin.lxd
committed
[FLINK-36315][cdc-base]Variable database changed to namespace
molin.lxd
committed
[FLINK-36315][cdc-base]Variable database changed to namespace
molin.lxd
committed

Commits on Oct 28, 2024

Commits on Oct 31, 2024

[FLINK-36315][cdc-base]Remove the finishedSplits variable from the SnapshotSplitAssigner class
molin.lxd
committed

Commits on Nov 5, 2024

[FLINK-36315][cdc-base]Update MySQL Source Metric UTs
molin.lxd
committed

Commits on Nov 6, 2024

[FLINK-36315][cdc-base]Add MySQL Source Metric UTs for DDL
molin.lxd
committed

Commits on Nov 8, 2024

[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed

Commits on Nov 12, 2024

[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed
[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed

Commits on Nov 13, 2024

[FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics
molin.lxd
committed
[FLINK-36315][cdc-base]Fix code style issues
molin.lxd
committed
[FLINK-36315][cdc-base]add enterStreamReading while isNewlyAddedAssigningFinished
molin.lxd
committed
[FLINK-36315][cdc-base]remove unused variable currentReadTimestampMs
molin.lxd
committed
[FLINK-36315][cdc-base]Variable database changed to namespace
molin.lxd
committed
[FLINK-36315][cdc-base]Variable database changed to namespace
molin.lxd
committed
Update flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java

authored and
molin.lxd
committed
[FLINK-36315][cdc-base]Adjust log format
molin.lxd
committed
[FLINK-36315][cdc-base]Remove the finishedSplits variable from the SnapshotSplitAssigner class
molin.lxd
committed
[FLINK-36315][cdc-base]Update MySQL Source Metric UTs
molin.lxd
committed
[FLINK-36315][cdc-base]Add MySQL Source Metric UTs for DDL
molin.lxd
committed
[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed
[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed
[FLINK-36315][cdc-base]Roll back some unrelated UT changes
molin.lxd
committed
Merge remote-tracking branch 'origin/cdc_base_support_metrics_36315' into cdc_base_support_metrics_36315
molin.lxd
committed

Commits on Nov 19, 2024

Merge branch 'master' into cdc_base_support_metrics_36315
molin.lxd
committed

Commits on Nov 22, 2024

[FLINK-36315][cdc-base]PendingSplitsStateSerializer UT support version 7
molin.lxd
committed
[FLINK-36315][cdc-base]PendingSplitsStateSerializer UT support version 7
molin.lxd
committed
[FLINK-36315][cdc-base]PendingSplitsStateSerializer UT support version 7
molin.lxd
committed
[FLINK-36315][cdc-base]PendingSplitsStateSerializer UT support version 7
molin.lxd
committed
[FLINK-36315][cdc-base]Fix code style issues
molin.lxd
committed

Commits on Dec 2, 2024

Commits on Dec 5, 2024

[FLINK-36315][cdc-base]Adjust the key of TableMetrics from splitId to chunkId
molin.lxd
committed