[hotfix] Fix dedicated compaction

[liyubin117]

Purpose

There are some failures related to delicated compaction

1. FlinkActionsWithKafkaE2eTest
Result is still unexpected after 60 retries.
Expected: {20221206, 1, 100=1, 20221205, 1, 100=1}
Actual: {}
	at org.apache.paimon.tests.E2eTestBase.checkResult(E2eTestBase.java:333)
	at org.apache.paimon.tests.FlinkActionsWithKafkaE2eTest.testCompact(FlinkActionsWithKafkaE2eTest.java:112)

2. CompactProcedureITCase
java.util.concurrent.TimeoutException: Cannot collect 2 records in 3 MINUTES
	at org.apache.paimon.utils.BlockingIterator.collect(BlockingIterator.java:84)
	at org.apache.paimon.utils.BlockingIterator.collect(BlockingIterator.java:72)
	at org.apache.paimon.flink.procedure.CompactProcedureITCase.testStreamingCompact(CompactProcedureITCase.java:138)

Tests

FlinkActionsWithKafkaE2eTest
CompactProcedureITCase

API and Format

Documentation

[JingsongLi]

+1