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

JDBCAppendTableSink not support flush by flushIntervalMills

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Later
    • 1.10.0
    • None
    • Connectors / JDBC
    • None
    • Hide
      We suggest to use JDBCUpsertTableSink in Table API & SQL which both support append-only queries and updating queries.
      JDBCAppendTableSink will be remove !
      Show
      We suggest to use JDBCUpsertTableSink in Table API & SQL which both support append-only queries and updating queries. JDBCAppendTableSink will be remove !

    Description

      JDBCAppendTableSink just support append by "JDBCAppendTableSinkBuilder#batchSize",not support like "JDBCUpsertTableSink#flushIntervalMills"

       

      If batchSize=5000 ,  my data rows=5000*N+1 ,then last one record could not be append !!

      Attachments

        Activity

          People

            Unassigned Unassigned
            michael ran ranqiqiang
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: