[jira] [Created] (FLINK-16328) Restart batch timer in JDBC sink

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16328) Restart batch timer in JDBC sink

Shang Yuanchun (Jira)
Roman Khachatryan created FLINK-16328:
-----------------------------------------

             Summary: Restart batch timer in JDBC sink
                 Key: FLINK-16328
                 URL: https://issues.apache.org/jira/browse/FLINK-16328
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
    Affects Versions: 1.10.0
            Reporter: Roman Khachatryan


During the review of [https://github.com/apache/flink/pull/11061]

the following issue was discovered by @kkl0u :
{quote}Here shouldn't we restart the timer? It seems like we may be in the situation where we flushed this batch because we reached the max size, so for the new one we have to set a new timer (renew the BatchIntervalMs), right?
{quote}
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)