flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850

Constructor <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (DefaultBulkResponseInspector.java:42)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (Opensearch2Sink.java:75)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:74)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:76)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:77)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:78)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:79)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:80)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Sink.java:81)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:341)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultRequestIndexer.<init>(org.apache.flink.connector.opensearch.sink.Opensearch2Writer, org.apache.flink.metrics.Counter)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:297)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:102)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:104)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:107)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:113)
Constructor <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2Writer.java:115)
Constructor <org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2DynamicSink.java:69)
Constructor <org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2DynamicSink.java:70)
Constructor <org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2DynamicSink.java:71)
Constructor <org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2DynamicSink.java:72)
Constructor <org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2DynamicSink.java:73)
Constructor <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearch2Emitter.java:56)
Constructor <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearch2Emitter.java:57)
Constructor <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearch2Emitter.java:58)
Constructor <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearch2Emitter.java:59)
Field <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.failureHandler> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (DefaultBulkResponseInspector.java:0)
Field <org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.failureHandler> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (Opensearch2Writer.java:0)
Method <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest, org.opensearch.action.bulk.BulkResponse)> calls method <org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable, java.lang.Throwable)> in (DefaultBulkResponseInspector.java:65)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.getBulkResponseInspectorFactory()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (Opensearch2Sink.java:0)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2Sink.getDeliveryGuarantee()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (Opensearch2Sink.java:0)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.build()> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:339)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.build()> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:340)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.buildNetworkClientConfig()> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:362)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:194)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:195)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:198)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:200)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushInterval(long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:172)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushMaxActions(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:143)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushMaxSizeMb(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:158)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkResponseInspectorFactory(org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:329)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionPassword(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:227)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionPathPrefix(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:239)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionRequestTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:252)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:264)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionUsername(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:215)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:131)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:128)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.InstantiationUtil.isSerializable(java.lang.Object)> in (Opensearch2SinkBuilder.java:99)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:97)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:98)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setFailureHandler(org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:314)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setHosts([Lorg.apache.http.HttpHost;)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:114)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setHosts([Lorg.apache.http.HttpHost;)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:115)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setRestClientFactory(org.apache.flink.connector.opensearch.sink.RestClientFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (Opensearch2SinkBuilder.java:302)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setSocketTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (Opensearch2SinkBuilder.java:277)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest, org.opensearch.action.bulk.BulkResponse)> calls method <org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable, java.lang.Throwable)> in (Opensearch2Writer.java:364)
Method <org.apache.flink.connector.opensearch.sink.Opensearch2Writer.blockingFlushAllActions()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (Opensearch2Writer.java:0)
Method <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter$1.getMetricGroup()> calls constructor <org.apache.flink.metrics.groups.UnregisteredMetricsGroup.<init>()> in (RowOpensearch2Emitter.java:69)
Method <org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter$1.getUserCodeClassLoader()> calls method <org.apache.flink.util.SimpleUserCodeClassLoader.create(java.lang.ClassLoader)> in (RowOpensearch2Emitter.java:74)