[FLINK-15389] JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.9.1
• Fix Version/s: 1.10.0
• Component/s: Connectors / JDBC
• Labels: pull-request-available
• Assignee: xiaodao
• Reporter: xiaodao
• Created: 25/Dec/19 03:57
• Updated: 30/Dec/19 11:55
• Resolved: 30/Dec/19 11:55

Description

when flushMaxSize set 1; then it will call fush  func every time;  it's no need to create schedule to flush data.

if (flushIntervalMills != 0)  it's better to modify with

if (flushIntervalMills != 0 and flushMaxSize != 1)

 

Issue Links

• links to: GitHub Pull Request #10712