[FLINK-29098] StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: table-store-0.3.0
• Fix Version/s: table-store-0.3.0, table-store-0.2.1
• Component/s: Table Store
• Labels: pull-request-available
• Assignee: Jane Chan
• Reporter: Jane Chan
• Created: 24/Aug/22 13:58
• Updated: 24/Sep/22 02:38
• Resolved: 29/Aug/22 05:21

Description

The cause for unstable CompositePkAndMultiPartitionedTableITCase#testEnableLogAndStreamingReadWriteMultiPartitionedRecordsWithMultiPk was found that the StoreWriteOperator#prepareCommit may get an empty log offset due to some condition where KafkaProducer#flush are not called.

Issue Links

• links to: GitHub Pull Request #279