You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Feng Jin (Jira)" <ji...@apache.org> on 2022/07/01 08:38:00 UTC

[jira] [Created] (FLINK-28345) Flink Jdbc connector should check batch count before flush

Feng Jin created FLINK-28345:
--------------------------------

             Summary: Flink Jdbc connector should check batch count before flush
                 Key: FLINK-28345
                 URL: https://issues.apache.org/jira/browse/FLINK-28345
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
    Affects Versions: 1.14.5, 1.15.0
            Reporter: Feng Jin


org.apache.flink.connector.jdbc.internal.JdbcOutputFormat#flush
{code:java}
//代码占位符
@Override
public synchronized void flush() throws IOException {
    checkFlushException();

    for (int i = 0; i <= executionOptions.getMaxRetries(); i++) {
        try {
            attemptFlush();
            batchCount = 0;
            break; 
   ....{code}
When flush the batch,  we should check batchCount  is grater than 0. Other wise it would cause some problem with some drivers that do not support empty batches, like clickhouse jdbc driver. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)