This is an automated email from the ASF dual-hosted git repository.
airblader pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit dfb0bfc085ab8aacc84f6d581c5e44137e8daff9
Author: Ingo Bürk <ingo.bu...@tngtech.com>
AuthorDate: Fri Dec 10 08:47:17 2021 +0100
[FLINK-25241][hotfix] Remove resolved violations
---
.../violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 7 -------
.../violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 1 -
2 files changed, 8 deletions(-)
diff --git
a/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
b/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
index 961af9f..34b4b88 100644
--- a/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
+++ b/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
@@ -101,13 +101,6 @@
org.apache.flink.connector.file.src.reader.BulkFormat.createReader(org.apache.fl
org.apache.flink.connector.file.src.reader.BulkFormat.restoreReader(org.apache.flink.configuration.Configuration,
org.apache.flink.connector.file.src.FileSourceSplit): Returned leaf type
org.apache.flink.connector.file.src.reader.BulkFormat$Reader does not satisfy:
reside outside of package 'org.apache.flink..' or annotated with @Public or
annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.connector.file.src.reader.FileRecordFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.Path, long, long): Returned leaf type
org.apache.flink.connector.file.src.reader.FileRecordFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.connector.file.src.reader.FileRecordFormat.restoreReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.Path, long, long, long): Returned leaf type
org.apache.flink.connector.file.src.reader.FileRecordFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.SimpleStreamFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream): Returned leaf type
org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.SimpleStreamFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream, long, long): Returned leaf type
org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.SimpleStreamFormat.restoreReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream, long, long, long): Returned leaf
type org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.StreamFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream, long, long): Returned leaf type
org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.StreamFormat.restoreReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream, long, long, long): Returned leaf
type org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.TextLineFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream): Returned leaf type
org.apache.flink.connector.file.src.reader.StreamFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
-org.apache.flink.connector.file.src.reader.TextLineFormat.createReader(org.apache.flink.configuration.Configuration,
org.apache.flink.core.fs.FSDataInputStream): Returned leaf type
org.apache.flink.connector.file.src.reader.TextLineFormat$Reader does not
satisfy: reside outside of package 'org.apache.flink..' or annotated with
@Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.connector.file.src.util.Pool.recycler(): Returned leaf type
org.apache.flink.connector.file.src.util.Pool$Recycler does not satisfy: reside
outside of package 'org.apache.flink..' or annotated with @Public or annotated
with @PublicEvolving or annotated with @Deprecated
org.apache.flink.connector.file.src.util.Utils.forEachRemaining(org.apache.flink.connector.file.src.reader.BulkFormat$Reader,
java.util.function.Consumer): Argument leaf type
org.apache.flink.connector.file.src.reader.BulkFormat$Reader does not satisfy:
reside outside of package 'org.apache.flink..' or annotated with @Public or
annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions.builder(): Returned
leaf type
org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions$JDBCExactlyOnceOptionsBuilder
does not satisfy: reside outside of package 'org.apache.flink..' or annotated
with @Public or annotated with @PublicEvolving or annotated with @Deprecated
diff --git
a/flink-architecture-tests/violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
b/flink-architecture-tests/violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
index fecc1f8..53f357a 100644
--- a/flink-architecture-tests/violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
+++ b/flink-architecture-tests/violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5
@@ -14,7 +14,6 @@ Method
<org.apache.flink.runtime.executiongraph.Execution.finishPartitionsAndUpd
Method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantDispatcherLeadership()>
calls method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()>
in (EmbeddedHaServicesWithLeadershipControl.java:67)
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:79)
Method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantResourceManagerLeadership()>
calls method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.grantLeadership()>
in (EmbeddedHaServicesWithLeadershipControl.java:93)
-Method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.lambda$new$0(java.lang.Integer,
org.apache.flink.runtime.checkpoint.EmbeddedCompletedCheckpointStore)> calls
method
<org.apache.flink.runtime.checkpoint.EmbeddedCompletedCheckpointStore.getShutdownStatus()>
in (EmbeddedHaServicesWithLeadershipControl.java:41)
Method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeDispatcherLeadership()>
calls method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()>
in (EmbeddedHaServicesWithLeadershipControl.java:61)
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:73)
Method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.revokeResourceManagerLeadership()>
calls method
<org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.revokeLeadership()>
in (EmbeddedHaServicesWithLeadershipControl.java:86)
