Fix Unstable test FlinkTableSinkITCase.testVersionMergeEngineWithTypeTimestampLTZ9

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Description

Test fail with several case.

case1: only read snapshot data.

ava.lang.AssertionError: Timeout after waiting 60096 ms for Flink job results. Expected 5 records but only received 3. This might indicate a job hang or insufficient data generation.
	at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.timeoutError(FlinkRowAssertionsUtils.java:157)
	at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.collectRowsWithTimeout(FlinkRowAssertionsUtils.java:115)
	at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.collectRowsWithTimeout(FlinkRowAssertionsUtils.java:94)
	at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.assertResultsIgnoreOrder(FlinkRowAssertionsUtils.java:49)
	at org.apache.fluss.flink.sink.FlinkTableSinkITCase.testVersionMergeEngineWithTypeTimestampLTZ9(FlinkTableSinkITCase.java:1063)

case2: It seems insert data is not in order. T

Expecting actual:
  ["+I[3, v33, 2024-12-27T12:00:00.123456789Z]",
    "+I[1, v1, 2024-12-27T12:00:00.123456789Z]",
    "+I[2, v2, 2024-12-27T12:00:00.123456789Z]",
    "-U[3, v33, 2024-12-27T12:00:00.123456789Z]",
    "+U[3, v3, 2024-12-27T12:00:00.123456789Z]"]
to contain exactly in any order:
  ["+I[1, v1, 2024-12-27T12:00:00.123456789Z]",
    "+I[2, v2, 2024-12-27T12:00:00.123456789Z]",
    "+I[3, v3, 2024-12-27T12:00:00.123456789Z]",
    "-U[3, v3, 2024-12-27T12:00:00.123456789Z]",
    "+U[3, v33, 2024-12-27T12:00:00.123456789Z]"]
elements not found:
  ["+I[3, v3, 2024-12-27T12:00:00.123456789Z]",
    "-U[3, v3, 2024-12-27T12:00:00.123456789Z]",
    "+U[3, v33, 2024-12-27T12:00:00.123456789Z]"]
and elements not expected:
  ["+I[3, v33, 2024-12-27T12:00:00.123456789Z]",
    "-U[3, v33, 2024-12-27T12:00:00.123456789Z]",
    "+U[3, v3, 2024-12-27T12:00:00.123456789Z]"]

+I[3, v33, 2024-12-27T12:00:00.123456789Z] is inserted before +I[3, v3, 2024-12-27T12:00:00.123456789Z]

Willingness to contribute

• I'm willing to submit a PR!