(flink-connector-jdbc) branch main updated: [FLINK-34467][connector/jdbc] Bump flink version to 1.20.0

[leonard]

This is an automated email from the ASF dual-hosted git repository.

leonard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git


The following commit(s) were added to refs/heads/main by this push:
     new 72f315f  [FLINK-34467][connector/jdbc] Bump flink version to 1.20.0
72f315f is described below

commit 72f315fcac5ab300ec06625696bcda33b2141cd7
Author: Peter Huang <huangzhenqiu0...@gmail.com>
AuthorDate: Mon Oct 21 03:31:54 2024 -0700

    [FLINK-34467][connector/jdbc] Bump flink version to 1.20.0
    
    This closes  #137.
---
 .github/workflows/push_pr.yml                      |   6 +-
 .github/workflows/weekly.yml                       |  11 +-
 .../6cdea252-f400-4c13-bc99-b325f2ebe333           | 264 +++++++++++++++++++++
 .../archunit-violations/stored.rules               |   8 +-
 pom.xml                                            |   3 +-
 5 files changed, 279 insertions(+), 13 deletions(-)

diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index 14fe800..88cb645 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -28,12 +28,8 @@ jobs:
   compile_and_test:
     strategy:
       matrix:
-        flink: [ 1.19-SNAPSHOT, 1.20-SNAPSHOT ]
+        flink: [1.20.0]
         jdk: [ '8, 11, 17, 21' ]
-        include:
-          - flink: 1.18-SNAPSHOT
-            jdk: '8, 11, 17'
-
     uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
     with:
       flink_version: ${{ matrix.flink }}
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index 2be2f3c..9a27cda 100644
--- a/.github/workflows/weekly.yml
+++ b/.github/workflows/weekly.yml
@@ -30,17 +30,18 @@ jobs:
     strategy:
       matrix:
         flink_branches: [{
-          flink: 1.18-SNAPSHOT,
-          jdk: '8, 11, 17',
-          branch: main
-        }, {
           flink: 1.19-SNAPSHOT,
           jdk: '8, 11, 17, 21',
           branch: main
-        }, {
+        },
+        {
           flink: 1.20-SNAPSHOT,
           jdk: '8, 11, 17, 21',
           branch: main
+        }, {
+          flink: 1.19.1,
+          jdk: '8, 11, 17, 21',
+          branch: v3.2
         }, {
           flink: 1.18.0,
           jdk: '8, 11, 17',
diff --git 
a/flink-connector-jdbc-core/archunit-violations/6cdea252-f400-4c13-bc99-b325f2ebe333
 
b/flink-connector-jdbc-core/archunit-violations/6cdea252-f400-4c13-bc99-b325f2ebe333
new file mode 100644
index 0000000..afc7243
--- /dev/null
+++ 
b/flink-connector-jdbc-core/archunit-violations/6cdea252-f400-4c13-bc99-b325f2ebe333
@@ -0,0 +1,264 @@
+Class 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog> 
extends class <org.apache.flink.table.catalog.AbstractCatalog> in 
(AbstractJdbcCatalog.java:0)
+Class 
<org.apache.flink.connector.jdbc.core.table.source.JdbcFilterPushdownPreparedStatementVisitor>
 extends class <org.apache.flink.table.expressions.ExpressionDefaultVisitor> in 
(JdbcFilterPushdownPreparedStatementVisitor.java:0)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls constructor 
<org.apache.flink.table.catalog.AbstractCatalog.<init>(java.lang.String, 
java.lang.String)> in (AbstractJdbcCatalog.java:123)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcFilterPushdownPreparedStatementVisitor.<init>(java.util.function.Function)>
 calls constructor 
<org.apache.flink.table.expressions.ExpressionDefaultVisitor.<init>()> in 
(JdbcFilterPushdownPreparedStatementVisitor.java:52)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> has parameter of type 
<[Lorg.apache.flink.table.types.DataType;> in (JdbcRowDataLookupFunction.java:0)
+Constructor 
<org.apache.flink.connector.jdbc.internal.TableJdbcUpsertOutputFormat.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.internal.JdbcOutputFormat$StatementExecutorFactory,
 
org.apache.flink.connector.jdbc.internal.JdbcOutputFormat$StatementExecutorFactory)>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(TableJdbcUpsertOutputFormat.java:0)
+Field 
<org.apache.flink.connector.jdbc.core.database.dialect.AbstractDialectConverter.fieldTypes>
 has type <[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(AbstractDialectConverter.java:0)
+Field 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.fieldDataTypes>
 has type <[Lorg.apache.flink.table.types.DataType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.getDatabase(java.lang.String)>
 calls constructor 
<org.apache.flink.table.catalog.CatalogDatabaseImpl.<init>(java.util.Map, 
java.lang.String)> in (AbstractJdbcCatalog.java:258)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.committer.JdbcCommitableSerializer.deserialize(int,
 [B)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(JdbcCommitableSerializer.java:34)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.committer.JdbcCommitableSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.committer.JdbcCommitable)>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(JdbcCommitableSerializer.java:27)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.committer.JdbcCommitableSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.committer.JdbcCommitable)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getSharedBuffer()> in 
(JdbcCommitableSerializer.java:29)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserialize(int,
 [B)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(JdbcWriterStateSerializer.java:48)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.read([B, int, 
int)> in (JdbcWriterStateSerializer.java:62)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.read([B, int, 
int)> in (JdbcWriterStateSerializer.java:70)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readByte()> 
in (JdbcWriterStateSerializer.java:60)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readByte()> 
in (JdbcWriterStateSerializer.java:68)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(JdbcWriterStateSerializer.java:57)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(JdbcWriterStateSerializer.java:65)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.deserializeV2(org.apache.flink.core.memory.DataInputDeserializer)>
 has parameter of type <org.apache.flink.core.memory.DataInputDeserializer> in 
(JdbcWriterStateSerializer.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(JdbcWriterStateSerializer.java:29)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getSharedBuffer()> in 
(JdbcWriterStateSerializer.java:42)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.write([B, int, 
int)> in (JdbcWriterStateSerializer.java:34)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.write([B, int, 
int)> in (JdbcWriterStateSerializer.java:40)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeByte(int)> in 
(JdbcWriterStateSerializer.java:33)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeByte(int)> in 
(JdbcWriterStateSerializer.java:39)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (JdbcWriterStateSerializer.java:30)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (JdbcWriterStateSerializer.java:36)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.equals(java.lang.Object)>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSource.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.getConfiguration()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSource.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.getResultExtractor()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSource.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.getSqlSplitEnumeratorProvider()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSource.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.getTypeInformation()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSource.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.SqlTemplateSplitEnumerator.getParameterValuesProvider()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(SqlTemplateSplitEnumerator.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.SqlTemplateSplitEnumerator.getSqlTemplate()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(SqlTemplateSplitEnumerator.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.getConnection()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSourceSplitReader.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.getResultSet()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSourceSplitReader.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.getSplits()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSourceSplitReader.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.getStatement()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcSourceSplitReader.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.JdbcDynamicTableFactory.checkAllOrNone(org.apache.flink.configuration.ReadableConfig,
 [Lorg.apache.flink.configuration.ConfigOption;)> has parameter of type 
<[Lorg.apache.flink.configuration.ConfigOption;> in 
(JdbcDynamicTableFactory.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createBufferReduceExecutor(org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions,
 [Lorg.apache.flink.table.types.logical.LogicalType;)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createDeleteExecutor(org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect,
 java.lang.String, [Ljava.lang.String;, 
[Lorg.apache.flink.table.types.logical.LogicalType;)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createInsertOrUpdateExecutor(org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect,
 java.lang.String, [Ljava.lang.String;, 
[Lorg.apache.flink.table.types.logical.LogicalType;, [I, [Ljava.lang.String;, 
[Lorg.apache.flink.table.types.logical.LogicalType;)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createRowKeyExtractor([Lorg.apache.flink.table.types.logical.LogicalType;,
 [I)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createSimpleBufferedExecutor(org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect,
 [Ljava.lang.String;, [Lorg.apache.flink.table.types.logical.LogicalType;, 
java.lang.String)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createSimpleRowExecutor(org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect,
 [Ljava.lang.String;, [Lorg.apache.flink.table.types.logical.LogicalType;, 
java.lang.String)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createUpsertRowExecutor(org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect,
 java.lang.String, [Ljava.lang.String;, 
[Lorg.apache.flink.table.types.logical.LogicalType;, [I, [Ljava.lang.String;, 
[Lorg.apache.flink.table.types.logical.LogicalType;)> has parameter of type 
<[Lorg.apache.flink.table.types.logical.LogicalType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.getPrimaryKey(org.apache.flink.table.data.RowData,
 [Lorg.apache.flink.table.data.RowData$FieldGetter;)> has parameter of type 
<[Lorg.apache.flink.table.data.RowData$FieldGetter;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.setFieldDataTypes([Lorg.apache.flink.table.types.DataType;)>
 has parameter of type <[Lorg.apache.flink.table.types.DataType;> in 
(JdbcOutputFormatBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataInputFormat.createInputSplits(int)>
 has return type <[Lorg.apache.flink.core.io.InputSplit;> in 
(JdbcRowDataInputFormat.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataInputFormat.getInputSplitAssigner([Lorg.apache.flink.core.io.InputSplit;)>
 calls constructor 
<org.apache.flink.api.common.io.DefaultInputSplitAssigner.<init>([Lorg.apache.flink.core.io.InputSplit;)>
 in (JdbcRowDataInputFormat.java:287)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataInputFormat.getInputSplitAssigner([Lorg.apache.flink.core.io.InputSplit;)>
 has parameter of type <[Lorg.apache.flink.core.io.InputSplit;> in 
(JdbcRowDataInputFormat.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.getDbConnection()>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcRowDataLookupFunction.java:0)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.from(javax.sql.XADataSource)>
 is annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(SimpleXaConnectionProvider.java:0)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.deserialize([B)>
 calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(TransactionId.java:96)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.deserialize([B)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(TransactionId.java:101)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.deserialize([B)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(TransactionId.java:98)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.deserialize([B)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(TransactionId.java:99)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.deserialize([B)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.readLong()> 
in (TransactionId.java:100)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.fromXid(int,
 [B, [B, boolean)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(TransactionId.java:83)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.fromXid(int,
 [B, [B, boolean)> calls constructor 
<org.apache.flink.core.memory.DataInputDeserializer.<init>([B)> in 
(TransactionId.java:87)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.fromXid(int,
 [B, [B, boolean)> calls method 
<org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(TransactionId.java:85)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.fromXid(int,
 [B, [B, boolean)> calls method 
<org.apache.flink.core.memory.DataInputDeserializer.readInt()> in 
(TransactionId.java:88)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.fromXid(int,
 [B, [B, boolean)> calls method 
<org.apache.flink.core.memory.DataInputDeserializer.readLong()> in 
(TransactionId.java:89)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getBranchQualifier()>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(TransactionId.java:172)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getBranchQualifier()>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getSharedBuffer()> in 
(TransactionId.java:175)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getBranchQualifier()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (TransactionId.java:173)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getBranchQualifier()>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeLong(long)> in 
(TransactionId.java:174)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getGlobalTransactionId()>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(TransactionId.java:158)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getGlobalTransactionId()>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getSharedBuffer()> in 
(TransactionId.java:161)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getGlobalTransactionId()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.write([B, int, 
int)> in (TransactionId.java:159)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getGlobalTransactionId()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (TransactionId.java:160)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.readJobId(org.apache.flink.core.memory.DataInputDeserializer)>
 calls method <org.apache.flink.core.memory.DataInputDeserializer.read([B)> in 
(TransactionId.java:110)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.readJobId(org.apache.flink.core.memory.DataInputDeserializer)>
 has parameter of type <org.apache.flink.core.memory.DataInputDeserializer> in 
(TransactionId.java:0)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls constructor 
<org.apache.flink.core.memory.DataOutputSerializer.<init>(int)> in 
(TransactionId.java:183)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.getSharedBuffer()> in 
(TransactionId.java:189)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.write([B, int, 
int)> in (TransactionId.java:184)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (TransactionId.java:185)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (TransactionId.java:186)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method <org.apache.flink.core.memory.DataOutputSerializer.writeInt(int)> 
in (TransactionId.java:188)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.serialize()>
 calls method 
<org.apache.flink.core.memory.DataOutputSerializer.writeLong(long)> in 
(TransactionId.java:187)
+Method 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.getConnection()> is 
annotated with <org.apache.flink.annotation.VisibleForTesting> in 
(JdbcOutputFormat.java:0)
+Constructor 
<org.apache.flink.connector.jdbc.JdbcConnectionOptions.<init>(java.lang.String, 
java.lang.String, int, java.util.Properties)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcConnectionOptions.java:50)
+Constructor 
<org.apache.flink.connector.jdbc.JdbcConnectionOptions.<init>(java.lang.String, 
java.lang.String, int, java.util.Properties)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcConnectionOptions.java:53)
+Constructor 
<org.apache.flink.connector.jdbc.JdbcConnectionOptions.<init>(java.lang.String, 
java.lang.String, int, java.util.Properties)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcConnectionOptions.java:57)
+Constructor 
<org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions.<init>(boolean, int, 
boolean, java.util.Optional, boolean)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcExactlyOnceOptions.java:75)
+Constructor <org.apache.flink.connector.jdbc.JdbcExecutionOptions.<init>(long, 
int, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(JdbcExecutionOptions.java:38)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractJdbcCatalog.java:126)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractJdbcCatalog.java:134)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractJdbcCatalog.java:136)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractJdbcCatalog.java:125)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.<init>(java.lang.ClassLoader,
 java.lang.String, java.lang.String, java.lang.String, java.util.Properties)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractJdbcCatalog.java:133)
+Constructor 
<org.apache.flink.connector.jdbc.core.database.dialect.AbstractDialectConverter.<init>(org.apache.flink.table.types.logical.RowType)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(AbstractDialectConverter.java:60)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.statements.JdbcQueryStatement, 
org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer, 
org.apache.flink.connector.base.DeliveryGuarantee, java.util.Collection, or 
[...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.<init>(org.apache.flink.configuration.Configuration,
 org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase$Provider,
 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor,
 org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.base.Del [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.<init>(org.apache.flink.configuration.Configuration,
 org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase$Provider,
 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor,
 org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.base.Del [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.<init>(org.apache.flink.configuration.Configuration,
 org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase$Provider,
 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor,
 org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.base.Del [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.<init>(org.apache.flink.configuration.Configuration,
 org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase$Provider,
 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor,
 org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.base.Del [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource.<init>(org.apache.flink.configuration.Configuration,
 org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase$Provider,
 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor,
 org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.base.Del [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumStateSerializer.<init>(org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumStateSerializer.java:47)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase,
 org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings, 
java.util.List)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumerator.java:61)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase,
 org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings, 
java.util.List)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumerator.java:62)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext,
 
org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSqlSplitEnumeratorBase,
 org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings, 
java.util.List)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumerator.java:68)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumeratorState.<init>(java.util.List,
 java.util.List, java.util.List, java.io.Serializable)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumeratorState.java:47)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumeratorState.<init>(java.util.List,
 java.util.List, java.util.List, java.io.Serializable)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumeratorState.java:48)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumeratorState.<init>(java.util.List,
 java.util.List, java.util.List, java.io.Serializable)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumeratorState.java:49)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.SqlTemplateSplitEnumerator.<init>(java.io.Serializable,
 java.lang.String, 
org.apache.flink.connector.jdbc.split.JdbcParameterValuesProvider)> calls 
method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SqlTemplateSplitEnumerator.java:54)
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.<init>(org.apache.flink.api.connector.source.SourceReaderContext,
 org.apache.flink.configuration.Configuration, 
org.apache.flink.api.common.typeinfo.TypeInformation, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider, 
org.apache.flink.connector.base.DeliveryGuarantee, 
org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls met [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitState.<init>(org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplit)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceSplitState.java:38)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.String, 
[Ljava.lang.Object;)> in (JdbcRowDataLookupFunct [...]
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:82)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:83)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:84)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:85)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:86)
+Constructor 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataLookupFunction.<init>(org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions,
 int, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, 
[Ljava.lang.String;, org.apache.flink.table.types.logical.RowType, 
java.util.List, [Ljava.io.Serializable;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcRowDataLookupFunction.java:87)
+Constructor 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.<init>(java.util.function.Supplier,
 java.lang.Integer)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SimpleXaConnectionProvider.java:81)
+Constructor 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.xid.XidImpl.<init>(int,
 [B, [B)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(XidImpl.java:46)
+Constructor 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.xid.XidImpl.<init>(int,
 [B, [B)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(XidImpl.java:47)
+Constructor 
<org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction.<init>(org.apache.flink.connector.jdbc.internal.JdbcOutputFormat)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(GenericJdbcSinkFunction.java:44)
+Constructor 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.internal.JdbcOutputFormat$StatementExecutorFactory)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcOutputFormat.java:87)
+Constructor 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.internal.JdbcOutputFormat$StatementExecutorFactory)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcOutputFormat.java:88)
+Constructor 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.<init>(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider,
 org.apache.flink.connector.jdbc.JdbcExecutionOptions, 
org.apache.flink.connector.jdbc.internal.JdbcOutputFormat$StatementExecutorFactory)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcOutputFormat.java:89)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:76)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:77)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:78)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:79)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:80)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:81)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:82)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor.<init>(java.lang.String,
 java.lang.String, java.lang.String, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
org.apache.flink.connector.jdbc.JdbcStatementBuilder, 
java.util.function.Function, java.util.function.Function)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(InsertOrUpdateJdbcExecutor.java:83)
+Method 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.open(org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer)>
 calls constructor 
<org.apache.flink.util.concurrent.ExecutorThreadFactory.<init>(java.lang.String)>
 in (JdbcOutputFormat.java:103)
+Method 
<org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.open(org.apache.flink.connector.jdbc.internal.JdbcOutputSerializer)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcOutputFormat.java:94)
+Method 
<org.apache.flink.connector.jdbc.internal.RowJdbcOutputFormat$Builder.build()> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (RowJdbcOutputFormat.java:132)
+Method 
<org.apache.flink.connector.jdbc.internal.TableJdbcUpsertOutputFormat.createUpsertRowExecutor(org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(TableJdbcUpsertOutputFormat.java:152)
+Method 
<org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions$Builder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (InternalJdbcConnectionOptions.java:202)
+Method 
<org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions$Builder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (InternalJdbcConnectionOptions.java:203)
+Method 
<org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions$Builder.setProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (InternalJdbcConnectionOptions.java:195)
+Method 
<org.apache.flink.connector.jdbc.internal.options.InternalJdbcConnectionOptions$Builder.setProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (InternalJdbcConnectionOptions.java:196)
+Method 
<org.apache.flink.connector.jdbc.split.JdbcNumericBetweenParametersProvider.getParameterValues()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (JdbcNumericBetweenParametersProvider.java:100)
+Method 
<org.apache.flink.connector.jdbc.split.JdbcNumericBetweenParametersProvider.ofBatchNum(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcNumericBetweenParametersProvider.java:87)
+Method 
<org.apache.flink.connector.jdbc.split.JdbcNumericBetweenParametersProvider.ofBatchSize(long)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcNumericBetweenParametersProvider.java:75)
+Method 
<org.apache.flink.connector.jdbc.split.JdbcSlideTimingParameterProvider.setOptionalState(java.io.Serializable)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(JdbcSlideTimingParameterProvider.java:76)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.parseNamedStatement(java.lang.String,
 java.util.Map)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (FieldNamedPreparedStatementImpl.java:247)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.prepareStatement(java.sql.Connection,
 java.lang.String, [Ljava.lang.String;, java.lang.String, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (FieldNamedPreparedStatementImpl.java:202)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.prepareStatement(java.sql.Connection,
 java.lang.String, [Ljava.lang.String;, java.lang.String, int)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (FieldNamedPreparedStatementImpl.java:212)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.prepareStatement(java.sql.Connection,
 java.lang.String, [Ljava.lang.String;, java.lang.String, int)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FieldNamedPreparedStatementImpl.java:187)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.prepareStatement(java.sql.Connection,
 java.lang.String, [Ljava.lang.String;, java.lang.String, int)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FieldNamedPreparedStatementImpl.java:188)
+Method 
<org.apache.flink.connector.jdbc.statement.FieldNamedPreparedStatementImpl.prepareStatement(java.sql.Connection,
 java.lang.String, [Ljava.lang.String;, java.lang.String, int)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (FieldNamedPreparedStatementImpl.java:189)
+Method 
<org.apache.flink.connector.jdbc.utils.JdbcUtils.getConnectionProperties(org.apache.flink.configuration.ReadableConfig)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(JdbcUtils.java:49)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableInsertOrUpdateStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.statement.StatementFactory, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter, 
org.apache.flink.connector.jdbc.core.database.dialect [...]
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableSimpleStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(TableSimpleStatementExecutor.java:48)
+Constructor 
<org.apache.flink.connector.jdbc.internal.executor.TableSimpleStatementExecutor.<init>(org.apache.flink.connector.jdbc.statement.StatementFactory,
 org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialectConverter)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(TableSimpleStatementExecutor.java:49)
+Constructor 
<org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions.<init>(java.lang.String,
 org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect, 
[Ljava.lang.String;, [I, [Ljava.lang.String;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcDmlOptions.java:51)
+Constructor 
<org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions.<init>(java.lang.String,
 org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect, 
[Ljava.lang.String;, [I, [Ljava.lang.String;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcDmlOptions.java:52)
+Constructor 
<org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions.<init>(java.lang.String,
 org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect, 
[Ljava.lang.String;, [I, [Ljava.lang.String;)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcDmlOptions.java:53)
+Constructor 
<org.apache.flink.connector.jdbc.internal.options.JdbcInsertOptions.<init>(java.lang.String,
 [I)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcInsertOptions.java:33)
+Constructor 
<org.apache.flink.connector.jdbc.split.CompositeJdbcParameterValuesProvider.<init>(org.apache.flink.connector.jdbc.split.JdbcParameterValuesProvider,
 org.apache.flink.connector.jdbc.split.JdbcParameterValuesProvider)> calls 
method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (CompositeJdbcParameterValuesProvider.java:34)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcNumericBetweenParametersProvider.<init>(long,
 long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcNumericBetweenParametersProvider.java:55)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcNumericBetweenParametersProvider.<init>(long,
 long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcNumericBetweenParametersProvider.java:68)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcSlideTimingParameterProvider.<init>(java.lang.Long,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcSlideTimingParameterProvider.java:46)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcSlideTimingParameterProvider.<init>(java.lang.Long,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcSlideTimingParameterProvider.java:49)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcSlideTimingParameterProvider.<init>(java.lang.Long,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcSlideTimingParameterProvider.java:53)
+Constructor 
<org.apache.flink.connector.jdbc.split.JdbcSlideTimingParameterProvider.<init>(java.lang.Long,
 long, long, long)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSlideTimingParameterProvider.java:45)
+Constructor 
<org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings.<init>(java.time.Duration,
 java.time.Duration)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(ContinuousUnBoundingSettings.java:44)
+Interface <org.apache.flink.connector.jdbc.JdbcStatementBuilder> extends 
interface <org.apache.flink.util.function.BiConsumerWithException> in 
(JdbcStatementBuilder.java:0)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer.deserializeJdbcSourceSplit(java.io.DataInputStream)>
 calls method <org.apache.flink.util.InstantiationUtil.deserializeObject([B, 
java.lang.ClassLoader)> in (JdbcSourceSplitSerializer.java:98)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplit)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceSplitSerializer.java:46)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer.serializeJdbcSourceSplit(java.io.DataOutputStream,
 org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplit)> 
calls method 
<org.apache.flink.util.InstantiationUtil.serializeObject(java.lang.Object)> in 
(JdbcSourceSplitSerializer.java:80)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer.serializeJdbcSourceSplit(java.io.DataOutputStream,
 org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplit)> 
calls method 
<org.apache.flink.util.InstantiationUtil.serializeObject(java.lang.Object)> in 
(JdbcSourceSplitSerializer.java:85)
+Method 
<org.apache.flink.connector.jdbc.core.table.JdbcDynamicTableFactory.checkAllOrNone(org.apache.flink.configuration.ReadableConfig,
 [Lorg.apache.flink.configuration.ConfigOption;)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> 
in (JdbcDynamicTableFactory.java:356)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcDynamicTableSink.validatePrimaryKey(org.apache.flink.table.connector.ChangelogMode)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (JdbcDynamicTableSink.java:69)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcOutputFormatBuilder.java:81)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcOutputFormatBuilder.java:82)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcOutputFormatBuilder.java:83)
+Method 
<org.apache.flink.connector.jdbc.core.table.sink.JdbcOutputFormatBuilder.createBufferReduceExecutor(org.apache.flink.connector.jdbc.internal.options.JdbcDmlOptions,
 [Lorg.apache.flink.table.types.logical.LogicalType;)> calls method 
<org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(JdbcOutputFormatBuilder.java:116)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcDynamicTableSource.getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource$LookupContext)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcDynamicTableSource.java:106)
+Method 
<org.apache.flink.connector.jdbc.core.table.source.JdbcRowDataInputFormat$Builder.setFetchSize(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcRowDataInputFormat.java:356)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.SimpleJdbcConnectionProvider.loadDriver(java.lang.String)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SimpleJdbcConnectionProvider.java:87)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.PoolingXaConnectionProvider.endAndPrepare(javax.transaction.xa.Xid)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(PoolingXaConnectionProvider.java:109)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.PoolingXaConnectionProvider.open()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(PoolingXaConnectionProvider.java:79)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.PoolingXaConnectionProvider.peekPooled()>
 calls method 
<org.apache.flink.util.ExceptionUtils.rethrow(java.lang.Throwable)> in 
(PoolingXaConnectionProvider.java:202)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.PoolingXaConnectionProvider.start(javax.transaction.xa.Xid)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(PoolingXaConnectionProvider.java:91)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.execute(org.apache.flink.connector.jdbc.datasource.connections.xa.XaCommand)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (SimpleXaConnectionProvider.java:261)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.getConnection()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(SimpleXaConnectionProvider.java:128)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.open()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(SimpleXaConnectionProvider.java:101)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.open()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (SimpleXaConnectionProvider.java:87)
+Method 
<org.apache.flink.connector.jdbc.datasource.connections.xa.SimpleXaConnectionProvider.recover()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (SimpleXaConnectionProvider.java:246)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.checkState()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (XaTransaction.java:121)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.checkState()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (XaTransaction.java:122)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.createTx(long)>
 calls method 
<org.apache.flink.util.ExceptionUtils.rethrowIOException(java.lang.Throwable)> 
in (XaTransaction.java:135)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.createTx(long)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (XaTransaction.java:130)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.open(org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriterState)>
 calls method 
<org.apache.flink.util.ExceptionUtils.rethrowIOException(java.lang.Throwable)> 
in (XaTransaction.java:86)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.XaTransaction.prepareTx()>
 calls method 
<org.apache.flink.util.ExceptionUtils.rethrowIOException(java.lang.Throwable)> 
in (XaTransaction.java:151)
+Method 
<org.apache.flink.connector.jdbc.datasource.transactions.xa.domain.TransactionId.getBranchQualifier()>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (TransactionId.java:169)
+Method 
<org.apache.flink.connector.jdbc.JdbcConnectionOptions$JdbcConnectionOptionsBuilder.withProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcConnectionOptions.java:116)
+Method 
<org.apache.flink.connector.jdbc.JdbcConnectionOptions$JdbcConnectionOptionsBuilder.withProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcConnectionOptions.java:117)
+Method 
<org.apache.flink.connector.jdbc.JdbcInputFormat$JdbcInputFormatBuilder.setFetchSize(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcInputFormat.java:407)
+Method 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.databaseExists(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractJdbcCatalog.java:227)
+Method 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.getDatabase(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (AbstractJdbcCatalog.java:254)
+Method 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.getPrimaryKey(java.sql.DatabaseMetaData,
 java.lang.String, java.lang.String, java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in 
(AbstractJdbcCatalog.java:200)
+Method 
<org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog.validateJdbcUrl(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(AbstractJdbcCatalog.java:586)
+Method 
<org.apache.flink.connector.jdbc.core.database.dialect.AbstractDialect$Range.of(int,
 int)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (AbstractDialect.java:256)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.build(org.apache.flink.connector.base.DeliveryGuarantee,
 org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:111)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.build(org.apache.flink.connector.base.DeliveryGuarantee,
 org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:112)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.build(org.apache.flink.connector.base.DeliveryGuarantee,
 org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:113)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.build(org.apache.flink.connector.base.DeliveryGuarantee,
 org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:114)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.build(org.apache.flink.connector.base.DeliveryGuarantee,
 org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions, 
org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)> 
calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:115)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildAtLeastOnce(org.apache.flink.connector.jdbc.JdbcConnectionOptions)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:67)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildAtLeastOnce(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:73)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildAtLeastOnce(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:78)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildExactlyOnce(org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions,
 
org.apache.flink.connector.jdbc.datasource.connections.xa.XaConnectionProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:101)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildExactlyOnce(org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions,
 
org.apache.flink.connector.jdbc.datasource.connections.xa.XaConnectionProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:102)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildExactlyOnce(org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions,
 org.apache.flink.util.function.SerializableSupplier)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:85)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.buildExactlyOnce(org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions,
 org.apache.flink.util.function.SerializableSupplier)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:86)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder.withExecutionOptions(org.apache.flink.connector.jdbc.JdbcExecutionOptions)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSinkBuilder.java:51)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.sink.writer.JdbcWriter.snapshotState(long)>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcWriter.java:192)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:295)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:304)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcSourceBuilder.java:276)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:291)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:292)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.build()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:289)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setConnectionProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:218)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setConnectionProperty(java.lang.String,
 java.lang.String)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:219)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setConnectionProvider(org.apache.flink.connector.jdbc.datasource.connections.JdbcConnectionProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceBuilder.java:259)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setDBUrl(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:169)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceBuilder.java:207)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setDriverName(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:161)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setJdbcParameterValuesProvider(org.apache.flink.connector.jdbc.split.JdbcParameterValuesProvider)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceBuilder.java:202)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setResultExtractor(org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:145)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setResultSetFetchSize(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcSourceBuilder.java:249)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setSplitReaderFetchBatchSize(int)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in (JdbcSourceBuilder.java:225)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setSql(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (JdbcSourceBuilder.java:136)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder.setTypeInformation(org.apache.flink.api.common.typeinfo.TypeInformation)>
 calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, 
java.lang.String)> in (JdbcSourceBuilder.java:178)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumStateSerializer.deserialize(int,
 [B)> calls method 
<org.apache.flink.util.InstantiationUtil.deserializeObject([B, 
java.lang.ClassLoader)> in (JdbcSourceEnumStateSerializer.java:110)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumeratorState)>
 calls method 
<org.apache.flink.util.InstantiationUtil.serializeObject(java.lang.Object)> in 
(JdbcSourceEnumStateSerializer.java:70)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumStateSerializer.serialize(org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumeratorState)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.String, [Ljava.lang.Object;)> in 
(JdbcSourceEnumStateSerializer.java:58)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.JdbcSourceEnumStateSerializer.serializeJdbcSourceSplits(java.io.DataOutputStream,
 java.util.List)> calls method 
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in 
(JdbcSourceEnumStateSerializer.java:86)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.enumerator.SqlTemplateSplitEnumerator$TemplateSqlSplitEnumeratorProvider.setSqlTemplate(java.lang.String)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, 
java.lang.Object)> in (SqlTemplateSplitEnumerator.java:118)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.fetch()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (JdbcSourceSplitReader.java:138)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.JdbcSourceSplitReader.finishSplit()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean, 
java.lang.Object)> in (JdbcSourceSplitReader.java:165)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.RowResultExtractor.extract(java.sql.ResultSet)>
 calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in 
(RowResultExtractor.java:33)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplit.getReaderPosition()>
 calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in 
(JdbcSourceSplit.java:71)
+Method 
<org.apache.flink.connector.jdbc.core.datastream.source.split.JdbcSourceSplitSerializer.deserializeJdbcSourceSplit(java.io.DataInputStream)>
 calls method <org.apache.flink.util.InstantiationUtil.deserializeObject([B, 
java.lang.ClassLoader)> in (JdbcSourceSplitSerializer.java:98)
\ No newline at end of file
diff --git a/flink-connector-jdbc-core/archunit-violations/stored.rules 
b/flink-connector-jdbc-core/archunit-violations/stored.rules
index 0f9bf9b..f672a47 100644
--- a/flink-connector-jdbc-core/archunit-violations/stored.rules
+++ b/flink-connector-jdbc-core/archunit-violations/stored.rules
@@ -1,10 +1,16 @@
 #
-#Tue May 28 16:21:17 CEST 2024
+#Thu Sep 19 20:56:19 PDT 2024
 Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @Public\ must\ be\ 
annotated\ with\ @Public.=596bd7eb-1ed5-4963-a56a-941766d61233
 Connector\ production\ code\ must\ not\ depend\ on\ non-public\ API\ outside\ 
of\ connector\ packages=f242ee43-a122-4d2f-a291-6439cdb9029f
+Classes\ in\ API\ packages\ should\ have\ at\ least\ one\ API\ visibility\ 
annotation.=0c7b60d6-a12c-432d-8a72-747cabaeb7ed
 ITCASE\ tests\ should\ use\ a\ MiniCluster\ resource\ or\ 
extension=6b9ab1b0-c14d-4667-bab5-407b81fba98b
 Production\ code\ must\ not\ call\ methods\ annotated\ with\ 
@VisibleForTesting=4bca2274-65a9-4a61-81ef-767d58233ea0
 Options\ for\ connectors\ and\ formats\ should\ reside\ in\ a\ consistent\ 
package\ and\ be\ public\ API.=b10c194a-0517-4744-830f-81abfb71ab18
 Tests\ inheriting\ from\ AbstractTestBase\ should\ have\ name\ ending\ with\ 
ITCase=0f94f11b-9bc8-445a-8be8-e7dfd8a384b0
+Options\ for\ connectors\ and\ formats\ should\ reside\ in\ a\ consistent\ 
package\ and\ be\ public\ API.=b10c194a-0517-4744-830f-81abfb71ab18
+Connector\ production\ code\ must\ not\ depend\ on\ non-public\ API\ outside\ 
of\ connector\ packages=f242ee43-a122-4d2f-a291-6439cdb9029f
+Production\ code\ must\ not\ call\ methods\ annotated\ with\ 
@VisibleForTesting=4bca2274-65a9-4a61-81ef-767d58233ea0
+Connector\ production\ code\ must\ depend\ only\ on\ public\ API\ when\ 
outside\ of\ connector\ packages=6cdea252-f400-4c13-bc99-b325f2ebe333
+Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @Public\ must\ be\ 
annotated\ with\ @Public.=596bd7eb-1ed5-4963-a56a-941766d61233
 Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @PublicEvolving\ 
must\ be\ annotated\ with\ 
@Public(Evolving).=d45c3af5-52c6-45fd-9926-75e75e77473a
 Classes\ in\ API\ packages\ should\ have\ at\ least\ one\ API\ visibility\ 
annotation.=0c7b60d6-a12c-432d-8a72-747cabaeb7ed
diff --git a/pom.xml b/pom.xml
index 9c2f6b9..1613290 100644
--- a/pom.xml
+++ b/pom.xml
@@ -56,10 +56,9 @@ under the License.
     </modules>
 
     <properties>
-        <flink.version>1.18.0</flink.version>
+        <flink.version>1.20.0</flink.version>
         <scala.binary.version>2.12</scala.binary.version>
         <scala-library.version>2.12.7</scala-library.version>
-
         <jackson-bom.version>2.13.4.20221013</jackson-bom.version>
         <junit4.version>4.13.2</junit4.version>
         <junit5.version>5.10.1</junit5.version>