[flink] add a test for ccovering the latest mode in scan.startup.mode configuration tests

[nhuantho]

Purpose

Linked issue: close #2471

Brief change log

• Overloading the collectRowsWithTimeout method allows passing maxWaitTime.
• Add a test for covering scan.startup.mode='latest'.

Tests

• fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java
  • Overloading the collectRowsWithTimeout method allows passing maxWaitTime.
• fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
  • testChangelogWithScanStartupMode -> add logic for testing scan.startup.mode='latest'