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

[MehulBatra]

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]

Dependencies

Merge after #2347