diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index 14fe8002d..c8d542a43 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -28,10 +28,10 @@ jobs:
   compile_and_test:
     strategy:
       matrix:
-        flink: [ 1.19-SNAPSHOT, 1.20-SNAPSHOT ]
+        flink: [ 1.19.1 ]
         jdk: [ '8, 11, 17, 21' ]
         include:
-          - flink: 1.18-SNAPSHOT
+          - flink: 1.20.0
             jdk: '8, 11, 17'
 
     uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index 2be2f3c81..9a27cdada 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 000000000..afc724344
--- /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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (JdbcWriter.java:95)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:100)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:101)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:122)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:123)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:82)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:84)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (JdbcWriter.java:92)
+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, org.apache.flink.api.connector.sink2.Sink$InitContext)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (JdbcWriter.java:102)
+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.DeliveryGuarantee, org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSource.java:78)
+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.DeliveryGuarantee, org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSource.java:79)
+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.DeliveryGuarantee, org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSource.java:80)
+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.DeliveryGuarantee, org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSource.java:81)
+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.DeliveryGuarantee, org.apache.flink.connector.jdbc.utils.ContinuousUnBoundingSettings)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSource.java:84)
+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 method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in (JdbcSourceSplitReader.java:117)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:104)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:105)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:106)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:107)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:112)
+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 method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (JdbcSourceSplitReader.java:120)
+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 (JdbcRowDataLookupFunction.java:95)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:64)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:65)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:66)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:67)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:68)
+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.JdbcDialectConverter, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (TableInsertOrUpdateStatementExecutor.java:69)
+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 0f9bf9b46..f672a47dc 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 fa8d48376..ec6a35496 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>