Skip to content

[flink] changelog read support for log table without pushdown optimizations #2441

Closed
MehulBatra wants to merge 4 commits intoapache:mainfrom
MehulBatra:change_log_scan_logtable
Closed

[flink] changelog read support for log table without pushdown optimizations #2441
MehulBatra wants to merge 4 commits intoapache:mainfrom
MehulBatra:change_log_scan_logtable

Conversation

@MehulBatra
Copy link
Copy Markdown
Contributor

@MehulBatra MehulBatra commented Jan 22, 2026

Purpose

Linked issue: close #2334

Brief change log

$changelog Support for Log Tables
Change Type: Log tables use +A (Append)

Modified Files

  • fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
  • Removed PK-only validation in getVirtualChangelogTable()

Tests:

  • fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
    • Renamed testChangelogVirtualTableWithNonPrimaryKeyTable → testChangelogVirtualTableWithLogTable
    • Now tests +A change type for log tables
  • fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java
    • Updated testGetChangelogVirtualTable() to verify log table schema instead of expecting error

@MehulBatra MehulBatra requested a review from wuchong January 22, 2026 11:29
@MehulBatra
Copy link
Copy Markdown
Contributor Author

Dependencies

Merge after #2347

@MehulBatra MehulBatra force-pushed the change_log_scan_logtable branch from db75838 to 1e5bddf Compare January 23, 2026 19:26
@MehulBatra MehulBatra closed this Jan 24, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[flink] Basic $changelog read support without pushdown optimizations for log table

1 participant