leonardBang / flink-sql-etl

Code / Commits / d19f81a
cdc source state analyze
Leonard Xu Leonard Xu committed on Jun 8, 2021, 09:09 AM
Showing 5 changed files +234 additions -2 deletions
M pom.xml +2 -1
M sql-avro/src/main/java/TestUserIssue12.java +1 -1
A state-process/pom.xml +45
A state-process/src/main/java/org/apache/flink/state/api/runtime/metadata/SavepointMetadata.java +134
A state-process/src/main/java/state/CdcSourceStateAnalysis.java +52
Browse files at this commit →