From d1441026cc289e36e9203c2fedb7f13da29e9716 Mon Sep 17 00:00:00 2001
From: Sergey Nuyanzin <snuyanzin@gmail.com>
Date: Fri, 4 Nov 2022 14:29:16 +0100
Subject: [PATCH] [FLINK-29846] Rgenerate violations because of
 https://github.com/TNG/ArchUnit/pull/957 and
 https://github.com/TNG/ArchUnit/pull/847

---
 .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8      |  2 +-
 .../b8900323-6aab-4e7e-9b17-f53b3c3dca46      | 92 ++++++++++---------
 .../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5      | 36 ++++----
 3 files changed, 66 insertions(+), 64 deletions(-)

diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
index 02c2583ee73ee..fdcd5bd1d0e20 100644
--- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
+++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
@@ -384,4 +384,4 @@ org.apache.flink.streaming.runtime.operators.windowing.TimestampedValue.getStrea
 org.apache.flink.streaming.runtime.streamrecord.LatencyMarker.getOperatorId(): Returned leaf type org.apache.flink.runtime.jobgraph.OperatorID does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
 org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware.setProcessingTimeService(org.apache.flink.streaming.runtime.tasks.ProcessingTimeService): Argument leaf type org.apache.flink.streaming.runtime.tasks.ProcessingTimeService does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
 org.apache.flink.table.operations.QueryOperation.accept(org.apache.flink.table.operations.QueryOperationVisitor): Argument leaf type org.apache.flink.table.operations.QueryOperationVisitor does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.types.parser.FieldParser.getErrorState(): Returned leaf type org.apache.flink.types.parser.FieldParser$ParseErrorState does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
+org.apache.flink.types.parser.FieldParser.getErrorState(): Returned leaf type org.apache.flink.types.parser.FieldParser$ParseErrorState does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
\ No newline at end of file
diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46
index f26ab80c5b20b..c4427924b397a 100644
--- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46
+++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46
@@ -15,13 +15,12 @@ Field <org.apache.flink.connector.hbase1.sink.HBaseDynamicTableSink.hbaseConf> h
 Field <org.apache.flink.connector.hbase2.sink.HBaseDynamicTableSink.hbaseConf> has type <org.apache.hadoop.conf.Configuration> in (HBaseDynamicTableSink.java:0)
 Method <org.apache.flink.connector.hbase.sink.HBaseSinkFunction.prepareRuntimeConfiguration()> calls method <org.apache.hadoop.conf.Configuration.get(java.lang.String)> in (HBaseSinkFunction.java:169)
 Method <org.apache.flink.connector.hbase.sink.HBaseSinkFunction.prepareRuntimeConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (HBaseSinkFunction.java:0)
-Method <org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.prepareRuntimeConfiguration()> calls method <org.apache.hadoop.conf.Configuration.get(java.lang.String)> in (HBaseRowDataLookupFunction.java:147)
+Method <org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.prepareRuntimeConfiguration()> calls method <org.apache.hadoop.conf.Configuration.get(java.lang.String)> in (HBaseRowDataLookupFunction.java:130)
 Method <org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.prepareRuntimeConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (HBaseRowDataLookupFunction.java:0)
-Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:113)
-Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:114)
+Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:101)
+Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:102)
+Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:108)
 Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.getHBaseConfiguration(org.apache.flink.configuration.ReadableConfig)> has return type <org.apache.hadoop.conf.Configuration> in (HBaseConnectorOptionsUtil.java:0)
-Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.lambda$getHBaseConfiguration$0(org.apache.hadoop.conf.Configuration, java.lang.Object, java.lang.Object)> calls method <org.apache.hadoop.conf.Configuration.set(java.lang.String, java.lang.String)> in (HBaseConnectorOptionsUtil.java:120)
-Method <org.apache.flink.connector.hbase.table.HBaseConnectorOptionsUtil.lambda$getHBaseConfiguration$0(org.apache.hadoop.conf.Configuration, java.lang.Object, java.lang.Object)> has parameter of type <org.apache.hadoop.conf.Configuration> in (HBaseConnectorOptionsUtil.java:0)
 Method <org.apache.flink.connector.hbase.util.HBaseConfigurationUtil.addHBaseConfIfFound(org.apache.hadoop.conf.Configuration, java.lang.String)> calls constructor <org.apache.hadoop.fs.Path.<init>(java.lang.String)> in (HBaseConfigurationUtil.java:106)
 Method <org.apache.flink.connector.hbase.util.HBaseConfigurationUtil.addHBaseConfIfFound(org.apache.hadoop.conf.Configuration, java.lang.String)> calls constructor <org.apache.hadoop.fs.Path.<init>(java.lang.String)> in (HBaseConfigurationUtil.java:96)
 Method <org.apache.flink.connector.hbase.util.HBaseConfigurationUtil.addHBaseConfIfFound(org.apache.hadoop.conf.Configuration, java.lang.String)> calls method <org.apache.hadoop.conf.Configuration.addResource(org.apache.hadoop.fs.Path)> in (HBaseConfigurationUtil.java:106)
@@ -49,44 +48,47 @@ Method <org.apache.flink.connector.hbase1.sink.HBaseDynamicTableSink.getConfigur
 Method <org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.getHadoopConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (AbstractTableInputFormat.java:0)
 Method <org.apache.flink.connector.hbase2.sink.HBaseDynamicTableSink.getConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (HBaseDynamicTableSink.java:0)
 Method <org.apache.flink.connector.hbase2.source.AbstractTableInputFormat.getHadoopConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (AbstractTableInputFormat.java:0)
-Method <org.apache.flink.connector.hbase2.source.HBaseRowDataAsyncLookupFunction.prepareRuntimeConfiguration()> calls method <org.apache.hadoop.conf.Configuration.get(java.lang.String)> in (HBaseRowDataAsyncLookupFunction.java:230)
+Method <org.apache.flink.connector.hbase2.source.HBaseRowDataAsyncLookupFunction.prepareRuntimeConfiguration()> calls method <org.apache.hadoop.conf.Configuration.get(java.lang.String)> in (HBaseRowDataAsyncLookupFunction.java:188)
 Method <org.apache.flink.connector.hbase2.source.HBaseRowDataAsyncLookupFunction.prepareRuntimeConfiguration()> has return type <org.apache.hadoop.conf.Configuration> in (HBaseRowDataAsyncLookupFunction.java:0)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$10(java.lang.Object)> calls method <oracle.jdbc.internal.OracleBlob.getBytes(long, int)> in (OracleRowConverter.java:128)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$10(java.lang.Object)> calls method <oracle.jdbc.internal.OracleBlob.length()> in (OracleRowConverter.java:128)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$10(java.lang.Object)> calls method <oracle.sql.RAW.getBytes()> in (OracleRowConverter.java:125)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$10(java.lang.Object)> checks instanceof <oracle.jdbc.internal.OracleBlob> in (OracleRowConverter.java:125)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$10(java.lang.Object)> checks instanceof <oracle.sql.RAW> in (OracleRowConverter.java:124)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$11(java.lang.Object)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:133)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$11(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:133)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$12(java.lang.Object)> calls method <oracle.sql.DATE.dateValue()> in (OracleRowConverter.java:137)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$12(java.lang.Object)> checks instanceof <oracle.sql.DATE> in (OracleRowConverter.java:136)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$13(java.lang.Object)> calls method <oracle.sql.DATE.timeValue()> in (OracleRowConverter.java:149)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$13(java.lang.Object)> checks instanceof <oracle.sql.DATE> in (OracleRowConverter.java:147)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$14(java.lang.Object)> calls method <oracle.sql.TIMESTAMP.timestampValue()> in (OracleRowConverter.java:155)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$14(java.lang.Object)> checks instanceof <oracle.sql.TIMESTAMP> in (OracleRowConverter.java:154)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$15(java.lang.Object)> calls method <oracle.sql.TIMESTAMPTZ.getTimeZone()> in (OracleRowConverter.java:164)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$15(java.lang.Object)> calls method <oracle.sql.TIMESTAMPTZ.timestampValue()> in (OracleRowConverter.java:163)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$15(java.lang.Object)> checks instanceof <oracle.sql.TIMESTAMPTZ> in (OracleRowConverter.java:159)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$2(java.lang.Object)> calls method <oracle.sql.NUMBER.booleanValue()> in (OracleRowConverter.java:65)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$2(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:65)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$3(java.lang.Object)> calls method <oracle.sql.BINARY_FLOAT.floatValue()> in (OracleRowConverter.java:71)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$3(java.lang.Object)> calls method <oracle.sql.NUMBER.floatValue()> in (OracleRowConverter.java:69)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$3(java.lang.Object)> checks instanceof <oracle.sql.BINARY_FLOAT> in (OracleRowConverter.java:69)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$3(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:68)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$4(java.lang.Object)> calls method <oracle.sql.BINARY_DOUBLE.doubleValue()> in (OracleRowConverter.java:80)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$4(java.lang.Object)> calls method <oracle.sql.NUMBER.doubleValue()> in (OracleRowConverter.java:78)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$4(java.lang.Object)> checks instanceof <oracle.sql.BINARY_DOUBLE> in (OracleRowConverter.java:78)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$4(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:77)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$5(java.lang.Object)> calls method <oracle.sql.NUMBER.byteValue()> in (OracleRowConverter.java:87)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$5(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:86)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$6(java.lang.Object)> calls method <oracle.sql.NUMBER.shortValue()> in (OracleRowConverter.java:92)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$6(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:91)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$7(java.lang.Object)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:97)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$7(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:96)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$8(java.lang.Object)> calls method <oracle.sql.NUMBER.longValue()> in (OracleRowConverter.java:102)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$8(java.lang.Object)> checks instanceof <oracle.sql.NUMBER> in (OracleRowConverter.java:101)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$9(java.lang.Object)> calls method <oracle.jdbc.internal.OracleClob.stringValue()> in (OracleRowConverter.java:118)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$9(java.lang.Object)> calls method <oracle.sql.CHAR.getString()> in (OracleRowConverter.java:116)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$9(java.lang.Object)> checks instanceof <oracle.jdbc.internal.OracleClob> in (OracleRowConverter.java:116)
-Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.lambda$createInternalConverter$224afae6$9(java.lang.Object)> checks instanceof <oracle.sql.CHAR> in (OracleRowConverter.java:115)
-Method <org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter.lambda$createPostgresArrayConverter$4f4cdb95$1(java.lang.Class, org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter$JdbcDeserializationConverter, java.lang.Object)> calls method <org.postgresql.jdbc.PgArray.getArray()> in (PostgresRowConverter.java:90)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.jdbc.internal.OracleBlob.getBytes(long, int)> in (OracleRowConverter.java:128)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.jdbc.internal.OracleBlob.length()> in (OracleRowConverter.java:128)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.jdbc.internal.OracleClob.stringValue()> in (OracleRowConverter.java:118)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.BINARY_DOUBLE.doubleValue()> in (OracleRowConverter.java:80)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.BINARY_FLOAT.floatValue()> in (OracleRowConverter.java:71)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.CHAR.getString()> in (OracleRowConverter.java:116)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.DATE.dateValue()> in (OracleRowConverter.java:137)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.DATE.timeValue()> in (OracleRowConverter.java:149)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.booleanValue()> in (OracleRowConverter.java:65)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.byteValue()> in (OracleRowConverter.java:87)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.doubleValue()> in (OracleRowConverter.java:78)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.floatValue()> in (OracleRowConverter.java:69)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:133)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:97)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.longValue()> in (OracleRowConverter.java:102)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.NUMBER.shortValue()> in (OracleRowConverter.java:92)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.RAW.getBytes()> in (OracleRowConverter.java:125)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.TIMESTAMP.timestampValue()> in (OracleRowConverter.java:155)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.TIMESTAMPTZ.getTimeZone()> in (OracleRowConverter.java:164)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <oracle.sql.TIMESTAMPTZ.timestampValue()> in (OracleRowConverter.java:163)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.jdbc.internal.OracleBlob.getBytes(long, int)> in (OracleRowConverter.java:128)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.jdbc.internal.OracleBlob.length()> in (OracleRowConverter.java:128)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.jdbc.internal.OracleClob.stringValue()> in (OracleRowConverter.java:118)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.BINARY_DOUBLE.doubleValue()> in (OracleRowConverter.java:80)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.BINARY_FLOAT.floatValue()> in (OracleRowConverter.java:71)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.CHAR.getString()> in (OracleRowConverter.java:116)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.DATE.dateValue()> in (OracleRowConverter.java:137)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.DATE.timeValue()> in (OracleRowConverter.java:149)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.booleanValue()> in (OracleRowConverter.java:65)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.byteValue()> in (OracleRowConverter.java:87)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.doubleValue()> in (OracleRowConverter.java:78)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.floatValue()> in (OracleRowConverter.java:69)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:133)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.intValue()> in (OracleRowConverter.java:97)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.longValue()> in (OracleRowConverter.java:102)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.NUMBER.shortValue()> in (OracleRowConverter.java:92)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.RAW.getBytes()> in (OracleRowConverter.java:125)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.TIMESTAMP.timestampValue()> in (OracleRowConverter.java:155)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.TIMESTAMPTZ.getTimeZone()> in (OracleRowConverter.java:164)
+Method <org.apache.flink.connector.jdbc.internal.converter.OracleRowConverter.createInternalConverter(org.apache.flink.table.types.logical.LogicalType)> calls method <oracle.sql.TIMESTAMPTZ.timestampValue()> in (OracleRowConverter.java:163)
+Method <org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter.$deserializeLambda$(java.lang.invoke.SerializedLambda)> calls method <org.postgresql.jdbc.PgArray.getArray()> in (PostgresRowConverter.java:87)
+Method <org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter.createPostgresArrayConverter(org.apache.flink.table.types.logical.ArrayType)> calls method <org.postgresql.jdbc.PgArray.getArray()> in (PostgresRowConverter.java:87)
\ No newline at end of file
diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
index 52bf0eb677218..7d502f7a21d18 100644
--- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
+++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
@@ -1,5 +1,5 @@
 Constructor <org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.<init>(org.apache.flink.runtime.state.heap.CopyOnWriteStateMap)> calls method <org.apache.flink.runtime.state.heap.CopyOnWriteStateMap.snapshotMapArrays()> in (CopyOnWriteStateMapSnapshot.java:86)
-Constructor <org.apache.flink.streaming.runtime.io.StreamTaskExternallyInducedSourceInput.<init>(org.apache.flink.streaming.api.operators.SourceOperator, java.util.function.Consumer, int, int)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (StreamTaskExternallyInducedSourceInput.java:39)
+Constructor <org.apache.flink.streaming.runtime.io.StreamTaskExternallyInducedSourceInput.<init>(org.apache.flink.streaming.api.operators.SourceOperator, java.util.function.Consumer, int, int)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (StreamTaskExternallyInducedSourceInput.java:41)
 Method <org.apache.flink.api.java.typeutils.runtime.TupleSerializerSnapshot.getNestedSerializers(org.apache.flink.api.java.typeutils.runtime.TupleSerializer)> calls method <org.apache.flink.api.java.typeutils.runtime.TupleSerializer.getFieldSerializers()> in (TupleSerializerSnapshot.java:70)
 Method <org.apache.flink.cep.nfa.sharedbuffer.LockableTypeSerializerSnapshot.getNestedSerializers(org.apache.flink.cep.nfa.sharedbuffer.Lockable$LockableTypeSerializer)> calls method <org.apache.flink.cep.nfa.sharedbuffer.Lockable$LockableTypeSerializer.getElementSerializer()> in (LockableTypeSerializerSnapshot.java:60)
 Method <org.apache.flink.orc.nohive.shim.OrcNoHiveShim.createRecordReader(org.apache.hadoop.conf.Configuration, org.apache.orc.TypeDescription, [I, java.util.List, org.apache.flink.core.fs.Path, long, long)> calls method <org.apache.flink.orc.shim.OrcShimV200.getOffsetAndLengthForSplit(long, long, java.util.List)> in (OrcNoHiveShim.java:62)
@@ -8,21 +8,21 @@ Method <org.apache.flink.runtime.blob.BlobInputStream.read([B, int, int)> calls
 Method <org.apache.flink.runtime.blob.BlobOutputStream.receiveAndCheckPutResponse(java.io.InputStream, java.security.MessageDigest, org.apache.flink.runtime.blob.BlobKey$BlobType)> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (BlobOutputStream.java:155)
 Method <org.apache.flink.runtime.blob.BlobUtils.checkAndDeleteCorruptedBlobs(java.nio.file.Path, org.slf4j.Logger)> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (BlobUtils.java:514)
 Method <org.apache.flink.runtime.blob.FileSystemBlobStore.get(java.lang.String, java.io.File, org.apache.flink.runtime.blob.BlobKey)> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (FileSystemBlobStore.java:124)
-Method <org.apache.flink.runtime.executiongraph.Execution.finishPartitionsAndUpdateConsumers()> calls method <org.apache.flink.runtime.executiongraph.ExecutionVertex.finishAllBlockingPartitions()> in (Execution.java:955)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantDispatcherLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:78)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantJobMasterLeadership(org.apache.flink.api.common.JobID)> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:90)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantResourceManagerLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:104)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeDispatcherLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:72)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeJobMasterLeadership(org.apache.flink.api.common.JobID)> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:84)
-Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeResourceManagerLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:97)
-Method <org.apache.flink.runtime.io.network.partition.ResourceManagerPartitionTrackerImpl.lambda$listDataSets$10(java.util.Map$Entry)> calls method <org.apache.flink.runtime.io.network.partition.DataSetMetaInfo.withNumRegisteredPartitions(int, int)> in (ResourceManagerPartitionTrackerImpl.java:269)
-Method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.closeAsync(long)> calls method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.quiesce()> in (RecreateOnResetOperatorCoordinator.java:332)
-Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerConfiguration.java:246)
-Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerConfiguration.java:248)
-Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerServices.java:395)
-Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerServices.java:393)
-Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.asClassLoader()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:269)
-Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.registerReleaseHookIfAbsent(java.lang.String, java.lang.Runnable)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:275)
+Method <org.apache.flink.runtime.executiongraph.Execution.finishPartitionsAndUpdateConsumers()> calls method <org.apache.flink.runtime.executiongraph.ExecutionVertex.finishAllBlockingPartitions()> in (Execution.java:978)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantDispatcherLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:83)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantJobMasterLeadership(org.apache.flink.api.common.JobID)> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:95)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantResourceManagerLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:109)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeDispatcherLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:77)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeJobMasterLeadership(org.apache.flink.api.common.JobID)> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:89)
+Method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeResourceManagerLeadership()> calls method <org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()> in (EmbeddedHaServicesWithLeadershipControl.java:102)
+Method <org.apache.flink.runtime.io.network.partition.ResourceManagerPartitionTrackerImpl.listDataSets()> calls method <org.apache.flink.runtime.io.network.partition.DataSetMetaInfo.withNumRegisteredPartitions(int, int)> in (ResourceManagerPartitionTrackerImpl.java:286)
+Method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.closeAsync(long)> calls method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.quiesce()> in (RecreateOnResetOperatorCoordinator.java:343)
+Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerConfiguration.java:244)
+Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerConfiguration.java:246)
+Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerServices.java:405)
+Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerServices.java:403)
+Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.asClassLoader()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:288)
+Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.registerReleaseHookIfAbsent(java.lang.String, java.lang.Runnable)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:294)
 Method <org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.getTransactionCoordinatorId()> calls method <org.apache.flink.streaming.connectors.kafka.internals.FlinkKafkaInternalProducer.getTransactionCoordinatorId()> in (FlinkKafkaProducer.java:1327)
-Method <org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask.init()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (SourceOperatorStreamTask.java:75)
-Method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.isIdle()> calls method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.isDefaultActionAvailable()> in (MailboxExecutorImpl.java:63)
+Method <org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask.init()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (SourceOperatorStreamTask.java:96)
+Method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.isIdle()> calls method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.isDefaultActionAvailable()> in (MailboxExecutorImpl.java:63)
\ No newline at end of file