Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-16328

Restart batch timer in JDBC sink after successful execution

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Reopened
    • Not a Priority
    • Resolution: Unresolved
    • 1.10.0
    • None
    • Connectors / JDBC
    • None

    Description

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

      the following issue was discovered by kkl0u :

      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?

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            roman Roman Khachatryan
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: