[flink] Extract shared checkpoint/savepoint utilities to base class

[MehulBatra]

Purpose

Linked issue: close #2758

Brief change log

New File:

• Created FlussVirtualTableITCaseBase.java
  • Shared @tempdir fields: checkpointDir, savepointDir
  • Shared utility methods: getFileBasedCheckpointsConfig(), waitForCheckpoint()

Modified:

• BinlogVirtualTableITCase.java
  • Now extends FlussVirtualTableITCaseBase
• ChangelogVirtualTableITCase.java
  • Now extends FlussVirtualTableITCaseBase

Tests

• All existing tests remain unchanged

API and Format

Documentation

[MehulBatra]

@wuchong @nhuantho Could you please help review!

[nhuantho]

Hi @MehulBatra, I was wondering why the initTableEnvironment method wasn’t moved to FlussVirtualTableITCaseBase.

[MehulBatra]

Hi @MehulBatra, I was wondering why the initTableEnvironment method wasn’t moved to FlussVirtualTableITCaseBase.

The method has test-specific dependencies that would couple the tests unnecessarily.

[nhuantho]

Hi, @MehulBatra, the idea of #2477 from FlinkTableSourceFailOverITCase. So, these methods are not only used in BinlogVirtualTableITCase and ChangelogVirtualTableITCase. Whether, can we create a util class like FinkCheckpointsUtils in src/test/java/org/apache/fluss/flink/source/testutils?