apache / fluss

[kv] Improve the implementation of AUTO_INCREMENT column

Jark Wu

Jark Wu committed on Jan 17, 2026, 06:37 AM

Showing 17 changed files +386 additions -166 deletions

M fluss-common/src/main/java/org/apache/fluss/config/TableConfig.java +1 -1

M fluss-common/src/main/java/org/apache/fluss/metadata/Schema.java +31 -9

M fluss-common/src/test/java/org/apache/fluss/metadata/TableSchemaTest.java +1 -1

M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/FlinkConnectorOptions.java +3 -2

M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/utils/FlinkConversionsTest.java +6 -11

M fluss-server/src/main/java/org/apache/fluss/server/kv/KvManager.java +10 -2

M fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/AutoIncrementManager.java +10 -24

M fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/BoundedSegmentSequenceGenerator.java +30 -34

M fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/PerSchemaAutoIncrementUpdater.java +11 -23

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/SequenceGeneratorFactory.java +38

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/ZkSequenceGeneratorFactory.java +61

M fluss-server/src/test/java/org/apache/fluss/server/kv/KvTabletTest.java +64 -2

M fluss-server/src/test/java/org/apache/fluss/server/kv/autoinc/SegmentSequenceGeneratorTest.java +19 -54

A fluss-server/src/test/java/org/apache/fluss/server/kv/autoinc/TestingSequenceGeneratorFactory.java +40

A fluss-server/src/test/java/org/apache/fluss/server/kv/autoinc/TestingSequenceIDCounter.java +54

M website/docs/engine-flink/ddl.md +6 -2

M website/docs/engine-flink/options.md +1 -1

Browse files at this commit →