This is an automated email from the ASF dual-hosted git repository.
pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 2c640558ce2 NIFI-16512 Removed redundant classes from production
classes (#11856)
2c640558ce2 is described below
commit 2c640558ce247bd0fd065a1e85a707b92d27d674
Author: dan-s1 <[email protected]>
AuthorDate: Thu Oct 29 11:55:13 2026 -0400
NIFI-16512 Removed redundant classes from production classes (#11856)
---
.../nifi/minifi/bootstrap/command/StartRunner.java | 2 +-
.../configuration/ConfigurationChangeCoordinator.java | 2 +-
.../bootstrap/service/MiNiFiExecCommandProvider.java | 4 +---
.../nifi/provenance/NoOpProvenanceRepository.java | 19 ++++++++-----------
.../org/apache/nifi/util/FlowFileUnpackagerV1.java | 2 +-
.../org/apache/nifi/util/FlowFileUnpackagerV2.java | 2 +-
.../org/apache/nifi/util/FlowFileUnpackagerV3.java | 2 +-
.../remote/io/http/HttpCommunicationsSession.java | 2 +-
.../remote/io/socket/SocketCommunicationsSession.java | 2 +-
.../apache/nifi/stream/io/LimitingInputStream.java | 2 +-
.../nifi/wali/SequentialAccessWriteAheadLog.java | 2 +-
.../nifi/mock/connector/server/MockStateManager.java | 9 ++++-----
.../mock/connectors/AllowableValuesConnector.java | 3 +--
.../nifi/mock/connectors/CronScheduleConnector.java | 2 +-
.../apache/nifi/mock/connectors/GenerateAndLog.java | 3 +--
.../nifi/mock/connectors/MissingBundleConnector.java | 3 +--
.../org/apache/nifi/amqp/processors/AMQPConsumer.java | 4 ++--
.../apache/nifi/amqp/processors/AMQPPublisher.java | 2 +-
.../java/org/apache/nifi/jasn1/JASN1RecordReader.java | 8 +++-----
.../bitbucket/BitbucketRepositoryClient.java | 2 +-
.../nifi/processors/aws/kinesis/ConsumeKinesis.java | 3 +--
.../apache/nifi/processors/aws/s3/PutS3Object.java | 2 +-
.../azure/storage/ListAzureBlobStorage_v12.java | 2 +-
.../azure/devops/AzureDevOpsRepositoryClient.java | 2 +-
.../elasticsearch/PutElasticsearchRecord.java | 5 ++---
.../nifi/processors/evtx/XmlBxmlNodeVisitor.java | 6 +++---
.../flow/git/AbstractGitFlowRegistryClient.java | 2 +-
.../access/WriteAvroSchemaAttributeStrategy.java | 5 ++---
.../nifi/processors/gcp/storage/ListGCSBucket.java | 2 +-
.../gcp/vision/AbstractStartGcpVisionOperation.java | 2 +-
.../apache/nifi/github/GitHubRepositoryClient.java | 2 +-
.../apache/nifi/gitlab/GitLabRepositoryClient.java | 2 +-
.../org/apache/nifi/graph/TinkerpopClientService.java | 3 +--
.../nifi/processors/groovyx/ExecuteGroovyScript.java | 2 +-
.../hadoop/util/ByteFilteringOutputStream.java | 3 +--
.../processors/hadoop/util/InputStreamWritable.java | 2 +-
.../nifi/processors/hadoop/util/StringSerDe.java | 2 +-
.../aws/AmazonMSKCredentialsCallbackHandler.java | 3 +--
.../nifi/processors/network/ParseNetflowv5.java | 4 +---
.../apache/nifi/parquet/stream/NifiOutputStream.java | 2 +-
.../nifi/processors/standard/DetectDuplicate.java | 2 +-
.../nifi/processors/standard/ExecuteProcess.java | 2 +-
.../processors/standard/FetchDistributedMapCache.java | 2 +-
.../processors/standard/PutDistributedMapCache.java | 2 +-
.../org/apache/nifi/processors/standard/SplitXml.java | 3 +--
.../nifi/kerberos/AbstractKerberosUserService.java | 3 +--
.../nifi/lookup/DistributedMapCacheLookupService.java | 2 +-
.../java/org/apache/nifi/cef/CEFRecordReader.java | 2 +-
.../java/org/apache/nifi/csv/WriteFastCSVResult.java | 4 ++--
.../apache/nifi/record/sink/LoggingRecordSink.java | 3 +--
.../apache/nifi/provenance/AbstractRecordWriter.java | 4 ++--
.../provenance/WriteAheadProvenanceRepository.java | 2 +-
.../nifi/provenance/expiration/FileRemovalAction.java | 5 ++---
.../nifi/provenance/lucene/UpdateMinimumEventId.java | 4 ++--
.../nifi/provenance/NoOpProvenanceRepository.java | 5 ++---
.../nifi/provenance/VolatileProvenanceRepository.java | 12 ++++++------
.../NiFiRegistryExternalResourceProvider.java | 2 +-
.../repository/VolatileFlowFileRepository.java | 14 +++++++-------
.../claim/StandardContentClaimWriteCache.java | 2 +-
.../repository/io/ArrayManagedOutputStream.java | 4 ++--
.../providers/local/WriteAheadLocalStateProvider.java | 2 +-
.../java/org/apache/nifi/jaxb/BulletinAdapter.java | 4 ++--
.../http/StandardHttpFlowFileServerProtocol.java | 12 ++++++------
.../org/apache/nifi/audit/ProcessGroupAuditor.java | 4 ++--
.../util/VirtualThreadParallelProcessingService.java | 3 +--
.../configuration/WebSecurityConfiguration.java | 2 +-
.../java/org/apache/nifi/util/MockProcessSession.java | 6 +++---
.../apache/nifi/util/StandardProcessorTestRunner.java | 2 +-
.../org/apache/nifi/registry/event/EventService.java | 2 +-
.../security/authorization/AuthorizerFactory.java | 2 +-
.../jetty/handler/ContextPathRedirectPatternRule.java | 3 +--
.../nifi/registry/db/MySqlDataSourceFactory.java | 4 +---
.../apache/nifi/registry/web/api/AccessResource.java | 2 +-
.../web/security/NiFiRegistrySecurityConfig.java | 2 +-
.../authorization/ResourceAuthorizationFilter.java | 2 +-
.../apache/nifi/extensions/NexusExtensionClient.java | 3 +--
.../nifi/stateless/flow/ExceptionalTriggerResult.java | 3 +--
.../apache/nifi/cs/tests/system/MockCSVReader.java | 3 +--
.../nifi/connectors/tests/system/AssetConnector.java | 2 +-
.../nifi/nar/provider/LocalDirectoryNarProvider.java | 2 +-
.../nar/provider/StandardClassLoaderInfoService.java | 5 +----
.../toolkit/client/impl/JerseyControllerClient.java | 2 +-
82 files changed, 125 insertions(+), 159 deletions(-)
diff --git
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/command/StartRunner.java
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/command/StartRunner.java
index 36e16331eaf..4cd5eeffbfc 100644
---
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/command/StartRunner.java
+++
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/command/StartRunner.java
@@ -337,7 +337,7 @@ public class StartRunner implements CommandRunner {
return process;
}
- private File getWorkingDir() throws IOException {
+ private File getWorkingDir() {
BootstrapProperties props =
bootstrapFileProvider.getBootstrapProperties();
File bootstrapConfigAbsoluteFile =
bootstrapConfigFile.getAbsoluteFile();
File binDir = bootstrapConfigAbsoluteFile.getParentFile();
diff --git
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
index 3308730aeea..c9dca2224c9 100644
---
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
+++
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
@@ -92,7 +92,7 @@ public class ConfigurationChangeCoordinator implements
Closeable, ConfigurationC
}
}
- private void initialize() throws IOException {
+ private void initialize() {
closeIngestors();
BootstrapProperties bootstrapProperties =
bootstrapFileProvider.getBootstrapProperties();
diff --git
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/MiNiFiExecCommandProvider.java
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/MiNiFiExecCommandProvider.java
index fe01176d679..69c60bf7cf5 100644
---
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/MiNiFiExecCommandProvider.java
+++
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/MiNiFiExecCommandProvider.java
@@ -20,7 +20,6 @@ package org.apache.nifi.minifi.bootstrap.service;
import org.apache.nifi.minifi.properties.BootstrapProperties;
import java.io.File;
-import java.io.IOException;
import java.nio.file.Path;
import java.util.List;
import java.util.Optional;
@@ -92,9 +91,8 @@ public class MiNiFiExecCommandProvider {
* @param listenPort the port where the Bootstrap process is listening
* @param workingDir working dir of the MiNiFi
* @return the list of arguments to start the process
- * @throws IOException throws IOException if any of the configuration file
read fails
*/
- public List<String> getMiNiFiExecCommand(int listenPort, File workingDir)
throws IOException {
+ public List<String> getMiNiFiExecCommand(int listenPort, File workingDir) {
BootstrapProperties bootstrapProperties =
bootstrapFileProvider.getBootstrapProperties();
File confDir = getFile(bootstrapProperties.getProperty(CONF_DIR_KEY,
DEFAULT_CONF_DIR).trim(), workingDir);
diff --git
a/minifi/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-provenance-repositories/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
b/minifi/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-provenance-repositories/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
index f413ae482ba..a6158a0ec00 100644
---
a/minifi/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-provenance-repositories/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
+++
b/minifi/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-provenance-repositories/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
@@ -24,7 +24,6 @@ import org.apache.nifi.provenance.search.Query;
import org.apache.nifi.provenance.search.QuerySubmission;
import org.apache.nifi.provenance.search.SearchableField;
-import java.io.IOException;
import java.util.List;
import java.util.Set;
@@ -40,13 +39,12 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
@Override
public void initialize(EventReporter eventReporter, Authorizer authorizer,
- ProvenanceAuthorizableFactory factory, IdentifierLookup
identifierLookup)
- throws IOException {
+ ProvenanceAuthorizableFactory factory, IdentifierLookup
identifierLookup) {
}
@Override
- public void close() throws IOException {
+ public void close() {
}
@@ -56,24 +54,23 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public ProvenanceEventRecord getEvent(long id) throws IOException {
+ public ProvenanceEventRecord getEvent(long id) {
return null;
}
@Override
- public ProvenanceEventRecord getEvent(final long id, final NiFiUser user)
throws IOException {
+ public ProvenanceEventRecord getEvent(final long id, final NiFiUser user) {
return null;
}
@Override
- public List<ProvenanceEventRecord> getEvents(long firstRecordId, int
maxRecords)
- throws IOException {
+ public List<ProvenanceEventRecord> getEvents(long firstRecordId, int
maxRecords) {
return emptyList();
}
@Override
public List<ProvenanceEventRecord> getEvents(long firstRecordId,
- int maxRecords, NiFiUser niFiUser) throws IOException {
+ int maxRecords, NiFiUser niFiUser) {
return emptyList();
}
@@ -138,7 +135,7 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public long getContainerCapacity(String s) throws IOException {
+ public long getContainerCapacity(String s) {
return 0;
}
@@ -148,7 +145,7 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public long getContainerUsableSpace(String s) throws IOException {
+ public long getContainerUsableSpace(String s) {
return 0;
}
diff --git
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV1.java
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV1.java
index 48c146a9a2b..e4adc74e123 100644
---
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV1.java
+++
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV1.java
@@ -79,7 +79,7 @@ public class FlowFileUnpackagerV1 implements
FlowFileUnpackager {
}
@Override
- public boolean hasMoreData() throws IOException {
+ public boolean hasMoreData() {
return flowFilesRead == 0;
}
diff --git
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV2.java
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV2.java
index 4fe0c20dc5f..be53c3a0c8b 100644
---
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV2.java
+++
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV2.java
@@ -33,7 +33,7 @@ public class FlowFileUnpackagerV2 implements
FlowFileUnpackager {
private boolean haveReadSomething = false;
@Override
- public boolean hasMoreData() throws IOException {
+ public boolean hasMoreData() {
return nextAttributes != null || !haveReadSomething;
}
diff --git
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV3.java
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV3.java
index aa0eb3b9ce3..3e6457a97ef 100644
---
a/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV3.java
+++
b/nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFileUnpackagerV3.java
@@ -33,7 +33,7 @@ public class FlowFileUnpackagerV3 implements
FlowFileUnpackager {
private final byte[] readBuffer = new byte[8192];
@Override
- public boolean hasMoreData() throws IOException {
+ public boolean hasMoreData() {
return nextHeader != null || !haveReadSomething;
}
diff --git
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/http/HttpCommunicationsSession.java
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/http/HttpCommunicationsSession.java
index cd5f5fbaa8f..c4e1317567b 100644
---
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/http/HttpCommunicationsSession.java
+++
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/http/HttpCommunicationsSession.java
@@ -37,7 +37,7 @@ public class HttpCommunicationsSession extends
AbstractCommunicationsSession {
}
@Override
- public void setTimeout(final int millis) throws IOException {
+ public void setTimeout(final int millis) {
this.timeout = millis;
}
diff --git
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/socket/SocketCommunicationsSession.java
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/socket/SocketCommunicationsSession.java
index 4dfb6e2d2e2..5015ed4b899 100644
---
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/socket/SocketCommunicationsSession.java
+++
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/io/socket/SocketCommunicationsSession.java
@@ -52,7 +52,7 @@ public class SocketCommunicationsSession extends
AbstractCommunicationsSession {
}
@Override
- public void setTimeout(final int millis) throws IOException {
+ public void setTimeout(final int millis) {
request.setTimeout(millis);
response.setTimeout(millis);
this.timeout = millis;
diff --git
a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/LimitingInputStream.java
b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/LimitingInputStream.java
index 31eb9eb2879..d5ec75f611e 100644
---
a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/LimitingInputStream.java
+++
b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/LimitingInputStream.java
@@ -41,7 +41,7 @@ public class LimitingInputStream extends InputStream {
this.limit = limit;
}
- public boolean hasReachedLimit() throws IOException {
+ public boolean hasReachedLimit() {
return limitReached;
}
diff --git
a/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/SequentialAccessWriteAheadLog.java
b/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/SequentialAccessWriteAheadLog.java
index dacce156e3f..7397a1fa768 100644
---
a/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/SequentialAccessWriteAheadLog.java
+++
b/nifi-commons/nifi-write-ahead-log/src/main/java/org/apache/nifi/wali/SequentialAccessWriteAheadLog.java
@@ -280,7 +280,7 @@ public class SequentialAccessWriteAheadLog<T> implements
WriteAheadRepository<T>
}
@Override
- public synchronized Set<String> getRecoveredSwapLocations() throws
IOException {
+ public synchronized Set<String> getRecoveredSwapLocations() {
if (!recovered) {
throw new IllegalStateException("Cannot retrieve the Recovered
Swap Locations until record recovery has been performed");
}
diff --git
a/nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/MockStateManager.java
b/nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/MockStateManager.java
index f22269ceabf..d08a1343c2a 100644
---
a/nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/MockStateManager.java
+++
b/nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/MockStateManager.java
@@ -21,7 +21,6 @@ import org.apache.nifi.components.state.Scope;
import org.apache.nifi.components.state.StateManager;
import org.apache.nifi.components.state.StateMap;
-import java.io.IOException;
import java.util.Collections;
import java.util.Map;
import java.util.concurrent.atomic.AtomicLong;
@@ -38,7 +37,7 @@ public class MockStateManager implements StateManager {
}
@Override
- public synchronized void setState(final Map<String, String> state, final
Scope scope) throws IOException {
+ public synchronized void setState(final Map<String, String> state, final
Scope scope) {
final StateMap newStateMap = new MockStateMap(state,
versionCounter.incrementAndGet());
if (scope == Scope.CLUSTER) {
@@ -49,7 +48,7 @@ public class MockStateManager implements StateManager {
}
@Override
- public synchronized StateMap getState(final Scope scope) throws
IOException {
+ public synchronized StateMap getState(final Scope scope) {
if (scope == Scope.CLUSTER) {
return clusterStateMap;
} else {
@@ -58,7 +57,7 @@ public class MockStateManager implements StateManager {
}
@Override
- public synchronized boolean replace(final StateMap oldValue, final
Map<String, String> newValue, final Scope scope) throws IOException {
+ public synchronized boolean replace(final StateMap oldValue, final
Map<String, String> newValue, final Scope scope) {
final StateMap currentStateMap = scope == Scope.CLUSTER ?
clusterStateMap : localStateMap;
if (currentStateMap == oldValue) {
@@ -77,7 +76,7 @@ public class MockStateManager implements StateManager {
}
@Override
- public synchronized void clear(final Scope scope) throws IOException {
+ public synchronized void clear(final Scope scope) {
setState(Collections.emptyMap(), scope);
}
diff --git
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/AllowableValuesConnector.java
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/AllowableValuesConnector.java
index d8172b7a2bb..24cb2f5bbec 100644
---
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/AllowableValuesConnector.java
+++
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/AllowableValuesConnector.java
@@ -24,7 +24,6 @@ import org.apache.nifi.components.connector.AbstractConnector;
import org.apache.nifi.components.connector.ConfigurationStep;
import org.apache.nifi.components.connector.ConnectorPropertyDescriptor;
import org.apache.nifi.components.connector.ConnectorPropertyGroup;
-import org.apache.nifi.components.connector.FlowUpdateException;
import org.apache.nifi.components.connector.components.FlowContext;
import org.apache.nifi.components.connector.components.FlowContextType;
import org.apache.nifi.components.connector.util.VersionedFlowUtils;
@@ -81,7 +80,7 @@ public class AllowableValuesConnector extends
AbstractConnector {
}
@Override
- public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) throws FlowUpdateException {
+ public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) {
}
@Override
diff --git
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/CronScheduleConnector.java
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/CronScheduleConnector.java
index e8473e27417..46fe401835b 100644
---
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/CronScheduleConnector.java
+++
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/CronScheduleConnector.java
@@ -94,7 +94,7 @@ public class CronScheduleConnector extends AbstractConnector {
}
@Override
- public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) throws FlowUpdateException {
+ public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) {
}
@Override
diff --git
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/GenerateAndLog.java
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/GenerateAndLog.java
index 40a6a5faa69..2278e80ea4d 100644
---
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/GenerateAndLog.java
+++
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/GenerateAndLog.java
@@ -20,7 +20,6 @@ package org.apache.nifi.mock.connectors;
import org.apache.nifi.components.ConfigVerificationResult;
import org.apache.nifi.components.connector.AbstractConnector;
import org.apache.nifi.components.connector.ConfigurationStep;
-import org.apache.nifi.components.connector.FlowUpdateException;
import org.apache.nifi.components.connector.components.FlowContext;
import org.apache.nifi.components.connector.util.VersionedFlowUtils;
import org.apache.nifi.flow.VersionedExternalFlow;
@@ -50,7 +49,7 @@ public class GenerateAndLog extends AbstractConnector {
}
@Override
- public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) throws FlowUpdateException {
+ public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) {
}
@Override
diff --git
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/MissingBundleConnector.java
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/MissingBundleConnector.java
index 1dad60bc72f..535f4a26669 100644
---
a/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/MissingBundleConnector.java
+++
b/nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors/src/main/java/org/apache/nifi/mock/connectors/MissingBundleConnector.java
@@ -20,7 +20,6 @@ package org.apache.nifi.mock.connectors;
import org.apache.nifi.components.ConfigVerificationResult;
import org.apache.nifi.components.connector.AbstractConnector;
import org.apache.nifi.components.connector.ConfigurationStep;
-import org.apache.nifi.components.connector.FlowUpdateException;
import org.apache.nifi.components.connector.components.FlowContext;
import org.apache.nifi.flow.Bundle;
import org.apache.nifi.flow.Position;
@@ -103,7 +102,7 @@ public class MissingBundleConnector extends
AbstractConnector {
}
@Override
- public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) throws FlowUpdateException {
+ public void applyUpdate(final FlowContext workingContext, final
FlowContext activeContext) {
}
@Override
diff --git
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
index b978fb99285..a891861ceed 100644
---
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
+++
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPConsumer.java
@@ -55,7 +55,7 @@ final class AMQPConsumer extends AMQPWorker {
final Channel channel = getChannel();
consumer = new DefaultConsumer(channel) {
@Override
- public void handleDelivery(final String consumerTag, final
Envelope envelope, final BasicProperties properties, final byte[] body) throws
IOException {
+ public void handleDelivery(final String consumerTag, final
Envelope envelope, final BasicProperties properties, final byte[] body) {
if (closed) {
// simply discard the messages, all unacknowledged
messages will be redelivered by the broker when the consumer connects again
processorLog.info("Consumer is closed, discarding message
(delivery tag: {}).", envelope.getDeliveryTag());
@@ -70,7 +70,7 @@ final class AMQPConsumer extends AMQPWorker {
}
@Override
- public void handleCancel(String consumerTag) throws IOException {
+ public void handleCancel(String consumerTag) {
processorLog.error("Consumer has been cancelled by the broker,
eg. due to deleted queue.");
try {
close();
diff --git
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
index fdb1b6ff720..db2e39c17ab 100644
---
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
+++
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPPublisher.java
@@ -152,7 +152,7 @@ final class AMQPPublisher extends AMQPWorker {
*/
private final class UndeliverableMessageLogger implements ReturnListener {
@Override
- public void handleReturn(int replyCode, String replyText, String
exchangeName, String routingKey, BasicProperties properties, byte[] message)
throws IOException {
+ public void handleReturn(int replyCode, String replyText, String
exchangeName, String routingKey, BasicProperties properties, byte[] message) {
final String reason = "Message returned as undeliverable by
broker: exchange='" + exchangeName
+ "' routingKey='" + routingKey + "' replyCode=" +
replyCode + " replyText='" + replyText + "'";
if (useConfirms) {
diff --git
a/nifi-extension-bundles/nifi-asn1-bundle/nifi-asn1-services/src/main/java/org/apache/nifi/jasn1/JASN1RecordReader.java
b/nifi-extension-bundles/nifi-asn1-bundle/nifi-asn1-services/src/main/java/org/apache/nifi/jasn1/JASN1RecordReader.java
index beed0cd8d03..261e6d269ab 100644
---
a/nifi-extension-bundles/nifi-asn1-bundle/nifi-asn1-services/src/main/java/org/apache/nifi/jasn1/JASN1RecordReader.java
+++
b/nifi-extension-bundles/nifi-asn1-bundle/nifi-asn1-services/src/main/java/org/apache/nifi/jasn1/JASN1RecordReader.java
@@ -19,7 +19,6 @@ package org.apache.nifi.jasn1;
import com.beanit.asn1bean.ber.types.BerType;
import org.apache.nifi.jasn1.convert.JASN1ConverterImpl;
import org.apache.nifi.logging.ComponentLog;
-import org.apache.nifi.serialization.MalformedRecordException;
import org.apache.nifi.serialization.RecordReader;
import org.apache.nifi.serialization.record.DataType;
import org.apache.nifi.serialization.record.MapRecord;
@@ -28,7 +27,6 @@ import org.apache.nifi.serialization.record.RecordField;
import org.apache.nifi.serialization.record.RecordSchema;
import org.apache.nifi.util.StringUtils;
-import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
@@ -124,7 +122,7 @@ public class JASN1RecordReader implements RecordReader {
@SuppressWarnings("unchecked")
@Override
- public Record nextRecord(boolean coerceTypes, boolean dropUnknownFields)
throws IOException, MalformedRecordException {
+ public Record nextRecord(boolean coerceTypes, boolean dropUnknownFields) {
return withClassLoader(() -> {
if (recordModelIterator == null) {
@@ -174,12 +172,12 @@ public class JASN1RecordReader implements RecordReader {
}
@Override
- public RecordSchema getSchema() throws MalformedRecordException {
+ public RecordSchema getSchema() {
return withClassLoader(() -> schemaProvider.get(recordModelClass));
}
@Override
- public void close() throws IOException {
+ public void close() {
}
}
diff --git
a/nifi-extension-bundles/nifi-atlassian-bundle/nifi-atlassian-extensions/src/main/java/org/apache/nifi/atlassian/bitbucket/BitbucketRepositoryClient.java
b/nifi-extension-bundles/nifi-atlassian-bundle/nifi-atlassian-extensions/src/main/java/org/apache/nifi/atlassian/bitbucket/BitbucketRepositoryClient.java
index a31cdeb6c33..f5e2a9b0308 100644
---
a/nifi-extension-bundles/nifi-atlassian-bundle/nifi-atlassian-extensions/src/main/java/org/apache/nifi/atlassian/bitbucket/BitbucketRepositoryClient.java
+++
b/nifi-extension-bundles/nifi-atlassian-bundle/nifi-atlassian-extensions/src/main/java/org/apache/nifi/atlassian/bitbucket/BitbucketRepositoryClient.java
@@ -537,7 +537,7 @@ public class BitbucketRepositoryClient implements
GitRepositoryClient {
@Override
public void createBranch(final String newBranchName, final String
sourceBranch, final Optional<String> sourceCommitSha)
- throws IOException, FlowRegistryException {
+ throws FlowRegistryException {
if (newBranchName == null || newBranchName.isBlank()) {
throw new IllegalArgumentException("Branch name must be
specified");
}
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/java/org/apache/nifi/processors/aws/kinesis/ConsumeKinesis.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/java/org/apache/nifi/processors/aws/kinesis/ConsumeKinesis.java
index 56fa367de72..ebb01ea7bbb 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/java/org/apache/nifi/processors/aws/kinesis/ConsumeKinesis.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/java/org/apache/nifi/processors/aws/kinesis/ConsumeKinesis.java
@@ -28,7 +28,6 @@ import org.apache.nifi.annotation.lifecycle.OnRemoved;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.components.Backlog;
-import org.apache.nifi.components.BacklogReportingException;
import org.apache.nifi.components.DescribedValue;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.components.Validator;
@@ -673,7 +672,7 @@ public class ConsumeKinesis extends AbstractProcessor
implements BacklogReportin
* backlog across shard-less nodes.
*/
@Override
- public Optional<Backlog> getBacklog(final ProcessContext context) throws
BacklogReportingException {
+ public Optional<Backlog> getBacklog(final ProcessContext context) {
final KinesisShardManager currentShardManager = shardManager;
if (currentShardManager == null) {
final Instant remembered = lastCaughtUpTimestamp;
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/PutS3Object.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/PutS3Object.java
index 19eef27f2f3..638630c202a 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/PutS3Object.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/PutS3Object.java
@@ -428,7 +428,7 @@ public class PutS3Object extends AbstractS3Processor {
}
}
- protected synchronized MultipartState getLocalState(final String
s3ObjectKey) throws IOException {
+ protected synchronized MultipartState getLocalState(final String
s3ObjectKey) {
// get local state if it exists
final File persistenceFile = getPersistenceFile();
diff --git
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
index 5165297db9b..47f3b90cd75 100644
---
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
+++
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
@@ -192,7 +192,7 @@ public class ListAzureBlobStorage_v12 extends
AbstractListAzureProcessor<BlobInf
}
@Override
- protected Integer countUnfilteredListing(ProcessContext context) throws
IOException {
+ protected Integer countUnfilteredListing(ProcessContext context) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-registry-clients/src/main/java/org/apache/nifi/azure/devops/AzureDevOpsRepositoryClient.java
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-registry-clients/src/main/java/org/apache/nifi/azure/devops/AzureDevOpsRepositoryClient.java
index 2d2c79d4f5e..3c16cdaf364 100644
---
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-registry-clients/src/main/java/org/apache/nifi/azure/devops/AzureDevOpsRepositoryClient.java
+++
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-registry-clients/src/main/java/org/apache/nifi/azure/devops/AzureDevOpsRepositoryClient.java
@@ -450,7 +450,7 @@ public class AzureDevOpsRepositoryClient implements
GitRepositoryClient {
@Override
public void createBranch(final String newBranchName, final String
sourceBranch, final Optional<String> sourceCommitSha)
- throws IOException, FlowRegistryException {
+ throws FlowRegistryException {
if (newBranchName == null || newBranchName.isBlank()) {
throw new IllegalArgumentException("Branch name must be
specified");
}
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchRecord.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchRecord.java
index 0a837dcf3ec..05725bd5367 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchRecord.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchRecord.java
@@ -55,7 +55,6 @@ import org.apache.nifi.record.path.util.RecordPathCache;
import org.apache.nifi.record.path.validation.RecordPathValidator;
import org.apache.nifi.schema.access.SchemaNotFoundException;
import org.apache.nifi.serialization.DateTimeFormatValidator;
-import org.apache.nifi.serialization.MalformedRecordException;
import org.apache.nifi.serialization.RecordReader;
import org.apache.nifi.serialization.RecordReaderFactory;
import org.apache.nifi.serialization.RecordSetWriter;
@@ -532,7 +531,7 @@ public class PutElasticsearchRecord extends
AbstractPutElasticsearch {
private void operate(final List<IndexOperationRequest> operationList,
final List<Record> processedRecords, final List<Record> originalRecords,
final RecordSchema recordSchema, final ProcessSession
session, final FlowFile input, final IndexOperationParameters
indexOperationParameters,
final List<FlowFile> resultRecords, final AtomicLong
erroredRecords, final AtomicLong successfulRecords)
- throws IOException, SchemaNotFoundException,
MalformedRecordException {
+ throws IOException, SchemaNotFoundException {
final BulkOperation bundle = new BulkOperation(operationList,
processedRecords, recordSchema);
final ResponseDetails responseDetails = indexDocuments(bundle,
originalRecords, session, input, indexOperationParameters);
@@ -556,7 +555,7 @@ public class PutElasticsearchRecord extends
AbstractPutElasticsearch {
private ResponseDetails indexDocuments(final BulkOperation bundle, final
List<Record> originalRecords, final ProcessSession session, final FlowFile
input,
final IndexOperationParameters
indexOperationParameters)
- throws IOException, SchemaNotFoundException,
MalformedRecordException {
+ throws IOException, SchemaNotFoundException {
final IndexOperationResponse response =
clientService.get().bulk(bundle.getOperationList(),
indexOperationParameters.getElasticsearchRequestOptions());
final Map<Integer, Map<String, Object>> errors =
findElasticsearchResponseErrors(response);
diff --git
a/nifi-extension-bundles/nifi-evtx-bundle/nifi-evtx-processors/src/main/java/org/apache/nifi/processors/evtx/XmlBxmlNodeVisitor.java
b/nifi-extension-bundles/nifi-evtx-bundle/nifi-evtx-processors/src/main/java/org/apache/nifi/processors/evtx/XmlBxmlNodeVisitor.java
index 20974c56345..95270766d89 100644
---
a/nifi-extension-bundles/nifi-evtx-bundle/nifi-evtx-processors/src/main/java/org/apache/nifi/processors/evtx/XmlBxmlNodeVisitor.java
+++
b/nifi-extension-bundles/nifi-evtx-bundle/nifi-evtx-processors/src/main/java/org/apache/nifi/processors/evtx/XmlBxmlNodeVisitor.java
@@ -173,17 +173,17 @@ public class XmlBxmlNodeVisitor implements
BxmlNodeVisitor {
}
@Override
- public void visit(VariantTypeNode variantTypeNode) throws IOException {
+ public void visit(VariantTypeNode variantTypeNode) {
value = variantTypeNode.getValue();
}
@Override
- public void visit(NormalSubstitutionNode normalSubstitutionNode)
throws IOException {
+ public void visit(NormalSubstitutionNode normalSubstitutionNode) {
value =
substitutions.get(normalSubstitutionNode.getIndex()).getValue();
}
@Override
- public void visit(ConditionalSubstitutionNode
conditionalSubstitutionNode) throws IOException {
+ public void visit(ConditionalSubstitutionNode
conditionalSubstitutionNode) {
value =
substitutions.get(conditionalSubstitutionNode.getIndex()).getValue();
}
}
diff --git
a/nifi-extension-bundles/nifi-extension-utils/nifi-git-flow-registry/src/main/java/org/apache/nifi/registry/flow/git/AbstractGitFlowRegistryClient.java
b/nifi-extension-bundles/nifi-extension-utils/nifi-git-flow-registry/src/main/java/org/apache/nifi/registry/flow/git/AbstractGitFlowRegistryClient.java
index 318e1597ca2..54089ab53d7 100644
---
a/nifi-extension-bundles/nifi-extension-utils/nifi-git-flow-registry/src/main/java/org/apache/nifi/registry/flow/git/AbstractGitFlowRegistryClient.java
+++
b/nifi-extension-bundles/nifi-extension-utils/nifi-git-flow-registry/src/main/java/org/apache/nifi/registry/flow/git/AbstractGitFlowRegistryClient.java
@@ -588,7 +588,7 @@ public abstract class AbstractGitFlowRegistryClient extends
AbstractFlowRegistry
return bucket;
}
- private RegisteredFlowSnapshotMetadata createSnapshotMetadata(final
GitCommit commit, final FlowLocation flowLocation) throws IOException {
+ private RegisteredFlowSnapshotMetadata createSnapshotMetadata(final
GitCommit commit, final FlowLocation flowLocation) {
final RegisteredFlowSnapshotMetadata snapshotMetadata = new
RegisteredFlowSnapshotMetadata();
snapshotMetadata.setBranch(flowLocation.getBranch());
snapshotMetadata.setBucketIdentifier(flowLocation.getBucketId());
diff --git
a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/schema/access/WriteAvroSchemaAttributeStrategy.java
b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/schema/access/WriteAvroSchemaAttributeStrategy.java
index 97389a9edb2..011dde349b6 100644
---
a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/schema/access/WriteAvroSchemaAttributeStrategy.java
+++
b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/src/main/java/org/apache/nifi/schema/access/WriteAvroSchemaAttributeStrategy.java
@@ -22,7 +22,6 @@ import com.github.benmanes.caffeine.cache.LoadingCache;
import org.apache.nifi.avro.AvroTypeUtil;
import org.apache.nifi.serialization.record.RecordSchema;
-import java.io.IOException;
import java.io.OutputStream;
import java.util.Collections;
import java.util.EnumSet;
@@ -36,7 +35,7 @@ public class WriteAvroSchemaAttributeStrategy implements
SchemaAccessWriter {
.build(schema ->
AvroTypeUtil.extractAvroSchema(schema).toString());
@Override
- public void writeHeader(final RecordSchema schema, final OutputStream out)
throws IOException {
+ public void writeHeader(final RecordSchema schema, final OutputStream out)
{
}
@Override
@@ -54,7 +53,7 @@ public class WriteAvroSchemaAttributeStrategy implements
SchemaAccessWriter {
}
@Override
- public void validateSchema(final RecordSchema schema) throws
SchemaNotFoundException {
+ public void validateSchema(final RecordSchema schema) {
}
@Override
diff --git
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/storage/ListGCSBucket.java
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/storage/ListGCSBucket.java
index 7f5daf6cbfa..d74123ade72 100644
---
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/storage/ListGCSBucket.java
+++
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/storage/ListGCSBucket.java
@@ -702,7 +702,7 @@ public class ListGCSBucket extends AbstractGCSProcessor {
}
@Override
- protected void createRecordsForEntities(ProcessContext context,
ProcessSession session, List<ListableBlob> updatedEntities) throws IOException,
SchemaNotFoundException {
+ protected void createRecordsForEntities(ProcessContext context,
ProcessSession session, List<ListableBlob> updatedEntities) {
publishListing(context, session, updatedEntities);
}
diff --git
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/vision/AbstractStartGcpVisionOperation.java
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/vision/AbstractStartGcpVisionOperation.java
index 7c82fe4531d..3486fd17de5 100644
---
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/vision/AbstractStartGcpVisionOperation.java
+++
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/vision/AbstractStartGcpVisionOperation.java
@@ -79,7 +79,7 @@ public abstract class AbstractStartGcpVisionOperation<B
extends Message.Builder>
}
@OnStopped
- public void onStopped() throws IOException {
+ public void onStopped() {
getVisionClient().close();
}
diff --git
a/nifi-extension-bundles/nifi-github-bundle/nifi-github-extensions/src/main/java/org/apache/nifi/github/GitHubRepositoryClient.java
b/nifi-extension-bundles/nifi-github-bundle/nifi-github-extensions/src/main/java/org/apache/nifi/github/GitHubRepositoryClient.java
index b6d8093a7ac..1360428ed85 100644
---
a/nifi-extension-bundles/nifi-github-bundle/nifi-github-extensions/src/main/java/org/apache/nifi/github/GitHubRepositoryClient.java
+++
b/nifi-extension-bundles/nifi-github-bundle/nifi-github-extensions/src/main/java/org/apache/nifi/github/GitHubRepositoryClient.java
@@ -114,7 +114,7 @@ public class GitHubRepositoryClient implements
GitRepositoryClient {
gitHubBuilder.withAbuseLimitHandler(new GitHubAbuseLimitHandler() {
@Override
- public void onError(GitHubConnectorResponse connectorResponse)
throws IOException {
+ public void onError(GitHubConnectorResponse connectorResponse) {
String message;
try (final InputStream stream =
connectorResponse.bodyStream()) {
message = new String(stream.readAllBytes());
diff --git
a/nifi-extension-bundles/nifi-gitlab-bundle/nifi-gitlab-extensions/src/main/java/org/apache/nifi/gitlab/GitLabRepositoryClient.java
b/nifi-extension-bundles/nifi-gitlab-bundle/nifi-gitlab-extensions/src/main/java/org/apache/nifi/gitlab/GitLabRepositoryClient.java
index aea6064589f..f54275af97d 100644
---
a/nifi-extension-bundles/nifi-gitlab-bundle/nifi-gitlab-extensions/src/main/java/org/apache/nifi/gitlab/GitLabRepositoryClient.java
+++
b/nifi-extension-bundles/nifi-gitlab-bundle/nifi-gitlab-extensions/src/main/java/org/apache/nifi/gitlab/GitLabRepositoryClient.java
@@ -308,7 +308,7 @@ public class GitLabRepositoryClient implements
GitRepositoryClient {
@Override
public void createBranch(final String newBranchName, final String
sourceBranch, final Optional<String> sourceCommitSha)
- throws IOException, FlowRegistryException {
+ throws FlowRegistryException {
if (StringUtils.isBlank(newBranchName)) {
throw new IllegalArgumentException("Branch name must be
specified");
}
diff --git
a/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/src/main/java/org/apache/nifi/graph/TinkerpopClientService.java
b/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/src/main/java/org/apache/nifi/graph/TinkerpopClientService.java
index 4f782735a6f..0fd5ee96078 100644
---
a/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/src/main/java/org/apache/nifi/graph/TinkerpopClientService.java
+++
b/nifi-extension-bundles/nifi-graph-bundle/nifi-other-graph-services/src/main/java/org/apache/nifi/graph/TinkerpopClientService.java
@@ -45,7 +45,6 @@ import org.apache.nifi.graph.gremlin.SimpleEntry;
import org.apache.nifi.migration.PropertyConfiguration;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
-import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.ssl.SSLContextProvider;
import org.apache.nifi.util.StringUtils;
import org.apache.nifi.util.file.classloader.ClassLoaderUtils;
@@ -246,7 +245,7 @@ public class TinkerpopClientService extends
AbstractControllerService implements
}
@OnEnabled
- public void onEnabled(final ConfigurationContext context) throws
InitializationException {
+ public void onEnabled(final ConfigurationContext context) {
loadClasses(context);
GroovyClassLoader loader = new
GroovyClassLoader(this.getClass().getClassLoader());
groovyShell = new GroovyShell(loader);
diff --git
a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
index 64b535dd317..96f037b3b9c 100644
---
a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
+++
b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
@@ -362,7 +362,7 @@ public class ExecuteGroovyScript extends AbstractProcessor {
/**
* init SQL variables from DBCP services
*/
- private void onInitSQL(Map<String, Object> sqlMap, Map<String, String>
attributes) throws SQLException {
+ private void onInitSQL(Map<String, Object> sqlMap, Map<String, String>
attributes) {
for (Map.Entry<String, Object> e : sqlMap.entrySet()) {
DBCPService s = (DBCPService) e.getValue();
OSql sql = new OSql(s.getConnection(attributes));
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/ByteFilteringOutputStream.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/ByteFilteringOutputStream.java
index 0145b3bf5a7..8307cba1196 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/ByteFilteringOutputStream.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/ByteFilteringOutputStream.java
@@ -33,8 +33,7 @@ public class ByteFilteringOutputStream extends
FilterOutputStream {
private final List<Filter> singleByteFilters = new ArrayList<>();
private final OutputStream wrapped;
- public ByteFilteringOutputStream(final OutputStream toWrap)
- throws IOException {
+ public ByteFilteringOutputStream(final OutputStream toWrap) {
super(toWrap);
this.wrapped = toWrap;
}
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/InputStreamWritable.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/InputStreamWritable.java
index a717b512439..002a1583e6e 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/InputStreamWritable.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/InputStreamWritable.java
@@ -54,7 +54,7 @@ public class InputStreamWritable implements Writable {
}
@Override
- public void readFields(DataInput di) throws IOException {
+ public void readFields(DataInput di) {
throw new UnsupportedOperationException("InputStreamWritable does not
implement #readFields");
}
}
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/StringSerDe.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/StringSerDe.java
index 106ebac6ada..f20e70487c8 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/StringSerDe.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/StringSerDe.java
@@ -28,7 +28,7 @@ import java.nio.charset.StandardCharsets;
public class StringSerDe implements Serializer<String>, Deserializer<String> {
@Override
- public String deserialize(final byte[] value) throws
DeserializationException, IOException {
+ public String deserialize(final byte[] value) throws
DeserializationException {
if (value == null) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-aws/src/main/java/org/apache/nifi/kafka/service/aws/AmazonMSKCredentialsCallbackHandler.java
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-aws/src/main/java/org/apache/nifi/kafka/service/aws/AmazonMSKCredentialsCallbackHandler.java
index c5cc84be75a..9bbf27af8a0 100644
---
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-aws/src/main/java/org/apache/nifi/kafka/service/aws/AmazonMSKCredentialsCallbackHandler.java
+++
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-aws/src/main/java/org/apache/nifi/kafka/service/aws/AmazonMSKCredentialsCallbackHandler.java
@@ -23,7 +23,6 @@ import
software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.msk.auth.iam.IAMLoginModule;
import software.amazon.msk.auth.iam.internals.AWSCredentialsCallback;
-import java.io.IOException;
import java.util.List;
import java.util.Map;
import javax.security.auth.callback.Callback;
@@ -64,7 +63,7 @@ public class AmazonMSKCredentialsCallbackHandler implements
AuthenticateCallback
}
@Override
- public void handle(final Callback[] callbacks) throws IOException,
UnsupportedCallbackException {
+ public void handle(final Callback[] callbacks) throws
UnsupportedCallbackException {
for (final Callback callback : callbacks) {
if (callback instanceof final AWSCredentialsCallback
awsCredentialsCallback) {
handleCredentialsCallback(awsCredentialsCallback);
diff --git
a/nifi-extension-bundles/nifi-network-bundle/nifi-network-processors/src/main/java/org/apache/nifi/processors/network/ParseNetflowv5.java
b/nifi-extension-bundles/nifi-network-bundle/nifi-network-processors/src/main/java/org/apache/nifi/processors/network/ParseNetflowv5.java
index 6445ee9a1be..3083625a57d 100644
---
a/nifi-extension-bundles/nifi-network-bundle/nifi-network-processors/src/main/java/org/apache/nifi/processors/network/ParseNetflowv5.java
+++
b/nifi-extension-bundles/nifi-network-bundle/nifi-network-processors/src/main/java/org/apache/nifi/processors/network/ParseNetflowv5.java
@@ -14,7 +14,6 @@
*/
package org.apache.nifi.processors.network;
-import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.apache.nifi.annotation.behavior.InputRequirement;
@@ -169,8 +168,7 @@ public class ParseNetflowv5 extends AbstractProcessor {
config.renameProperty("FIELDS_DESTINATION",
FIELDS_DESTINATION.getName());
}
- private void generateJSON(final List<FlowFile> multipleRecords, final
ProcessSession session, final FlowFile flowFile, final Netflowv5Parser parser,
final int processedRecord)
- throws JsonProcessingException {
+ private void generateJSON(final List<FlowFile> multipleRecords, final
ProcessSession session, final FlowFile flowFile, final Netflowv5Parser parser,
final int processedRecord) {
int numberOfRecords = processedRecord;
FlowFile recordFlowFile = flowFile;
int record = 0;
diff --git
a/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/parquet/stream/NifiOutputStream.java
b/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/parquet/stream/NifiOutputStream.java
index 8296554ca5d..a8954f3ffb2 100644
---
a/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/parquet/stream/NifiOutputStream.java
+++
b/nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/parquet/stream/NifiOutputStream.java
@@ -32,7 +32,7 @@ public class NifiOutputStream extends PositionOutputStream {
}
@Override
- public long getPos() throws IOException {
+ public long getPos() {
return position;
}
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java
index d816e8a2184..cc726a8dcfa 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java
@@ -257,7 +257,7 @@ public class DetectDuplicate extends AbstractProcessor {
@Override
@SuppressWarnings("PMD.UnnecessaryCast")
- public CacheValue deserialize(final byte[] input) throws
DeserializationException, IOException {
+ public CacheValue deserialize(final byte[] input) throws
DeserializationException {
if (input.length == 0) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteProcess.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteProcess.java
index 282af7f3b0a..c028c510d0c 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteProcess.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteProcess.java
@@ -499,7 +499,7 @@ public class ExecuteProcess extends AbstractProcessor {
}
@Override
- public void close() throws IOException {
+ public void close() {
}
@Override
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java
index e69716237fd..22c26f8b395 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java
@@ -281,7 +281,7 @@ public class FetchDistributedMapCache extends
AbstractProcessor {
public static class CacheValueDeserializer implements Deserializer<byte[]>
{
@Override
- public byte[] deserialize(final byte[] input) throws
DeserializationException, IOException {
+ public byte[] deserialize(final byte[] input) throws
DeserializationException {
if (input == null || input.length == 0) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java
index 3b4d055e297..d5d9e8af217 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java
@@ -234,7 +234,7 @@ public class PutDistributedMapCache extends
AbstractProcessor {
public static class CacheValueDeserializer implements Deserializer<byte[]>
{
@Override
- public byte[] deserialize(final byte[] input) throws
DeserializationException, IOException {
+ public byte[] deserialize(final byte[] input) throws
DeserializationException {
if (input == null || input.length == 0) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitXml.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitXml.java
index 7919a6eed6a..59919296318 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitXml.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitXml.java
@@ -43,7 +43,6 @@ import org.xml.sax.Attributes;
import org.xml.sax.ContentHandler;
import org.xml.sax.InputSource;
import org.xml.sax.Locator;
-import org.xml.sax.SAXException;
import java.io.BufferedInputStream;
import java.io.InputStream;
@@ -196,7 +195,7 @@ public class SplitXml extends AbstractProcessor {
}
@Override
- public void characters(char[] ch, int start, int length) throws
SAXException {
+ public void characters(char[] ch, int start, int length) {
// if we're not at a level where we care about capturing text,
then return
if (depth <= splitDepth) {
return;
diff --git
a/nifi-extension-bundles/nifi-standard-services/nifi-kerberos-user-service-bundle/nifi-kerberos-user-service/src/main/java/org/apache/nifi/kerberos/AbstractKerberosUserService.java
b/nifi-extension-bundles/nifi-standard-services/nifi-kerberos-user-service-bundle/nifi-kerberos-user-service/src/main/java/org/apache/nifi/kerberos/AbstractKerberosUserService.java
index 9fab41a5616..51d38638567 100644
---
a/nifi-extension-bundles/nifi-standard-services/nifi-kerberos-user-service-bundle/nifi-kerberos-user-service/src/main/java/org/apache/nifi/kerberos/AbstractKerberosUserService.java
+++
b/nifi-extension-bundles/nifi-standard-services/nifi-kerberos-user-service-bundle/nifi-kerberos-user-service/src/main/java/org/apache/nifi/kerberos/AbstractKerberosUserService.java
@@ -25,7 +25,6 @@ import org.apache.nifi.controller.ConfigurationContext;
import org.apache.nifi.controller.ControllerServiceInitializationContext;
import org.apache.nifi.expression.ExpressionLanguageScope;
import org.apache.nifi.processor.util.StandardValidators;
-import org.apache.nifi.reporting.InitializationException;
import java.io.File;
import java.util.ArrayList;
@@ -49,7 +48,7 @@ public abstract class AbstractKerberosUserService extends
AbstractControllerServ
private volatile String principal;
@Override
- protected final void init(final ControllerServiceInitializationContext
config) throws InitializationException {
+ protected final void init(final ControllerServiceInitializationContext
config) {
kerberosConfigFile = config.getKerberosConfigurationFile();
}
diff --git
a/nifi-extension-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/DistributedMapCacheLookupService.java
b/nifi-extension-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/DistributedMapCacheLookupService.java
index 46dcfab1321..0c788be912c 100644
---
a/nifi-extension-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/DistributedMapCacheLookupService.java
+++
b/nifi-extension-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/main/java/org/apache/nifi/lookup/DistributedMapCacheLookupService.java
@@ -130,7 +130,7 @@ public class DistributedMapCacheLookupService extends
AbstractControllerService
public static class StringDeserializer implements Deserializer<String> {
@Override
- public String deserialize(final byte[] input) throws
DeserializationException, IOException {
+ public String deserialize(final byte[] input) throws
DeserializationException {
if (input == null || input.length == 0) {
return null;
}
diff --git
a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/cef/CEFRecordReader.java
b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/cef/CEFRecordReader.java
index 0199176db14..a9bacc1d986 100644
---
a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/cef/CEFRecordReader.java
+++
b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/cef/CEFRecordReader.java
@@ -199,7 +199,7 @@ final class CEFRecordReader implements RecordReader {
}
@Override
- public RecordSchema getSchema() throws MalformedRecordException {
+ public RecordSchema getSchema() {
return schema;
}
diff --git
a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/csv/WriteFastCSVResult.java
b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/csv/WriteFastCSVResult.java
index 2e2f0ae331c..817efe8f7e8 100644
---
a/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/csv/WriteFastCSVResult.java
+++
b/nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/csv/WriteFastCSVResult.java
@@ -125,7 +125,7 @@ public class WriteFastCSVResult extends
AbstractRecordSetWriter implements Recor
}
@Override
- protected Map<String, String> onFinishRecordSet() throws IOException {
+ protected Map<String, String> onFinishRecordSet() {
includeHeaderIfNecessary(null, true);
return schemaWriter.getAttributes(recordSchema);
}
@@ -151,7 +151,7 @@ public class WriteFastCSVResult extends
AbstractRecordSetWriter implements Recor
return fieldNames;
}
- private void includeHeaderIfNecessary(final Record record, final boolean
schemaOnly) throws IOException {
+ private void includeHeaderIfNecessary(final Record record, final boolean
schemaOnly) {
if (headerWritten || !includeHeaderLine) {
return;
}
diff --git
a/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/main/java/org/apache/nifi/record/sink/LoggingRecordSink.java
b/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/main/java/org/apache/nifi/record/sink/LoggingRecordSink.java
index b0526478965..200c83b645b 100644
---
a/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/main/java/org/apache/nifi/record/sink/LoggingRecordSink.java
+++
b/nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/main/java/org/apache/nifi/record/sink/LoggingRecordSink.java
@@ -25,7 +25,6 @@ import org.apache.nifi.controller.ConfigurationContext;
import org.apache.nifi.logging.ComponentLog;
import org.apache.nifi.logging.LogLevel;
import org.apache.nifi.migration.PropertyConfiguration;
-import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.schema.access.SchemaNotFoundException;
import org.apache.nifi.serialization.RecordSetWriter;
import org.apache.nifi.serialization.RecordSetWriterFactory;
@@ -64,7 +63,7 @@ public class LoggingRecordSink extends
AbstractControllerService implements Reco
}
@OnEnabled
- public void onEnabled(final ConfigurationContext context) throws
InitializationException {
+ public void onEnabled(final ConfigurationContext context) {
writerFactory =
context.getProperty(RECORD_WRITER_FACTORY).asControllerService(RecordSetWriterFactory.class);
logLevel = LogLevel.valueOf(context.getProperty(LOG_LEVEL).getValue());
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/AbstractRecordWriter.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/AbstractRecordWriter.java
index 33859362c8d..b5d6d2daf93 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/AbstractRecordWriter.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/AbstractRecordWriter.java
@@ -39,7 +39,7 @@ public abstract class AbstractRecordWriter implements
RecordWriter {
private volatile boolean dirty = false;
private volatile boolean closed = false;
- public AbstractRecordWriter(final File file, final TocWriter writer)
throws IOException {
+ public AbstractRecordWriter(final File file, final TocWriter writer) {
logger.trace("Creating Record Writer for {}", file);
this.file = file;
@@ -47,7 +47,7 @@ public abstract class AbstractRecordWriter implements
RecordWriter {
this.tocWriter = writer;
}
- public AbstractRecordWriter(final String storageLocation, final TocWriter
writer) throws IOException {
+ public AbstractRecordWriter(final String storageLocation, final TocWriter
writer) {
logger.trace("Creating Record Writer for {}", storageLocation);
this.file = null;
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
index 23f619a2535..b47d2cbc3a1 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
@@ -341,7 +341,7 @@ public class WriteAheadProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public long getContainerUsableSpace(String containerName) throws
IOException {
+ public long getContainerUsableSpace(String containerName) {
Map<String, File> map = config.getStorageDirectories();
File container = map.get(containerName);
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/expiration/FileRemovalAction.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/expiration/FileRemovalAction.java
index c1e6199b519..b07cfa0d06d 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/expiration/FileRemovalAction.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/expiration/FileRemovalAction.java
@@ -21,14 +21,13 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
-import java.io.IOException;
public class FileRemovalAction implements ExpirationAction {
private static final Logger logger =
LoggerFactory.getLogger(FileRemovalAction.class);
@Override
- public File execute(final File expiredFile) throws IOException {
+ public File execute(final File expiredFile) {
final boolean removed = remove(expiredFile);
if (removed) {
logger.info("Removed expired Provenance Event file {}",
expiredFile);
@@ -57,7 +56,7 @@ public class FileRemovalAction implements ExpirationAction {
}
@Override
- public boolean hasBeenPerformed(final File expiredFile) throws IOException
{
+ public boolean hasBeenPerformed(final File expiredFile) {
return !expiredFile.exists();
}
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/UpdateMinimumEventId.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/UpdateMinimumEventId.java
index 420d5cece0c..94b6178f0b7 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/UpdateMinimumEventId.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/UpdateMinimumEventId.java
@@ -37,7 +37,7 @@ public class UpdateMinimumEventId implements ExpirationAction
{
}
@Override
- public File execute(final File expiredFile) throws IOException {
+ public File execute(final File expiredFile) {
try (final RecordReader reader =
RecordReaders.newRecordReader(expiredFile, null, Integer.MAX_VALUE)) {
final long maxEventId = reader.getMaxEventId();
indexConfig.setMinIdIndexed(maxEventId);
@@ -51,7 +51,7 @@ public class UpdateMinimumEventId implements ExpirationAction
{
}
@Override
- public boolean hasBeenPerformed(final File expiredFile) throws IOException
{
+ public boolean hasBeenPerformed(final File expiredFile) {
return !expiredFile.exists();
}
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
index b429842c404..3a3194faa5a 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/NoOpProvenanceRepository.java
@@ -28,7 +28,6 @@ import org.apache.nifi.provenance.search.SearchableField;
import org.apache.nifi.reporting.Severity;
import org.apache.nifi.util.NiFiProperties;
-import java.io.IOException;
import java.util.Collection;
import java.util.Date;
import java.util.List;
@@ -67,7 +66,7 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
*/
@Override
public void initialize(EventReporter eventReporter, Authorizer authorizer,
- ProvenanceAuthorizableFactory factory,
IdentifierLookup identifierLookup) throws IOException {
+ ProvenanceAuthorizableFactory factory,
IdentifierLookup identifierLookup) {
eventReporter.reportEvent(Severity.INFO, "Provenance", "Initialized
NoOpProvenanceRepository - Provenance tracking is disabled");
}
@@ -75,7 +74,7 @@ public class NoOpProvenanceRepository implements
ProvenanceRepository {
* Closes the repository. No-op.
*/
@Override
- public void close() throws IOException {
+ public void close() {
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/VolatileProvenanceRepository.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/VolatileProvenanceRepository.java
index 5a130230b30..13457d613f0 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/VolatileProvenanceRepository.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-volatile-provenance-repository/src/main/java/org/apache/nifi/provenance/VolatileProvenanceRepository.java
@@ -130,7 +130,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
@Override
public void initialize(final EventReporter eventReporter, final Authorizer
authorizer, final ProvenanceAuthorizableFactory resourceFactory,
- final IdentifierLookup idLookup) throws IOException {
+ final IdentifierLookup idLookup) {
if (initialized.getAndSet(true)) {
return;
}
@@ -165,7 +165,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public List<ProvenanceEventRecord> getEvents(final long firstRecordId,
final int maxRecords) throws IOException {
+ public List<ProvenanceEventRecord> getEvents(final long firstRecordId,
final int maxRecords) {
return getEvents(firstRecordId, maxRecords, null);
}
@@ -210,7 +210,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public void close() throws IOException {
+ public void close() {
queryExecService.shutdownNow();
scheduledExecService.shutdown();
}
@@ -565,7 +565,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
throw new AccessDeniedException("Cannot retrieve Provenance Lineage
Submission because " + user.getIdentity() + " is not the user who submitted the
request.");
}
- public Lineage expandSpawnEventParents(String identifier) throws
IOException {
+ public Lineage expandSpawnEventParents(String identifier) {
throw new UnsupportedOperationException();
}
@@ -628,7 +628,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public long getContainerCapacity(final String containerName) throws
IOException {
+ public long getContainerCapacity(final String containerName) {
return maxSize;
}
@@ -638,7 +638,7 @@ public class VolatileProvenanceRepository implements
ProvenanceRepository {
}
@Override
- public long getContainerUsableSpace(String containerName) throws
IOException {
+ public long getContainerUsableSpace(String containerName) {
return maxSize - ringBuffer.getSize();
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/registry/extension/NiFiRegistryExternalResourceProvider.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/registry/extension/NiFiRegistryExternalResourceProvider.java
index 464265ee645..b770cc60ef2 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/registry/extension/NiFiRegistryExternalResourceProvider.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/registry/extension/NiFiRegistryExternalResourceProvider.java
@@ -75,7 +75,7 @@ public class NiFiRegistryExternalResourceProvider implements
ExternalResourcePro
}
@Override
- public InputStream fetchExternalResource(final ExternalResourceDescriptor
descriptor) throws IOException {
+ public InputStream fetchExternalResource(final ExternalResourceDescriptor
descriptor) {
if (!initialized) {
LOGGER.error("Provider is not initialized");
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/VolatileFlowFileRepository.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/VolatileFlowFileRepository.java
index 726894796e7..cb66de72a74 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/VolatileFlowFileRepository.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/VolatileFlowFileRepository.java
@@ -50,12 +50,12 @@ public class VolatileFlowFileRepository implements
FlowFileRepository {
}
@Override
- public long getStorageCapacity() throws IOException {
+ public long getStorageCapacity() {
return 1L;
}
@Override
- public long getUsableStorageSpace() throws IOException {
+ public long getUsableStorageSpace() {
return 0L;
}
@@ -142,12 +142,12 @@ public class VolatileFlowFileRepository implements
FlowFileRepository {
}
@Override
- public long loadFlowFiles(final QueueProvider queueProvider) throws
IOException {
+ public long loadFlowFiles(final QueueProvider queueProvider) {
return 0;
}
@Override
- public Set<String> findQueuesWithFlowFiles(FlowFileSwapManager
swapManager) throws IOException {
+ public Set<String> findQueuesWithFlowFiles(FlowFileSwapManager
swapManager) {
return Collections.emptySet();
}
@@ -172,16 +172,16 @@ public class VolatileFlowFileRepository implements
FlowFileRepository {
}
@Override
- public long getMaxFlowFileIdentifier() throws IOException {
+ public long getMaxFlowFileIdentifier() {
return idGenerator.get() - 1;
}
@Override
- public void swapFlowFilesIn(String swapLocation, List<FlowFileRecord>
flowFileRecords, FlowFileQueue queue) throws IOException {
+ public void swapFlowFilesIn(String swapLocation, List<FlowFileRecord>
flowFileRecords, FlowFileQueue queue) {
}
@Override
- public void swapFlowFilesOut(List<FlowFileRecord> swappedOut,
FlowFileQueue queue, String swapLocation) throws IOException {
+ public void swapFlowFilesOut(List<FlowFileRecord> swappedOut,
FlowFileQueue queue, String swapLocation) {
}
@Override
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/claim/StandardContentClaimWriteCache.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/claim/StandardContentClaimWriteCache.java
index 7203d47874f..38b22662e76 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/claim/StandardContentClaimWriteCache.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/claim/StandardContentClaimWriteCache.java
@@ -136,7 +136,7 @@ public class StandardContentClaimWriteCache implements
ContentClaimWriteCache {
}
@Override
- public void flush() throws IOException {
+ public void flush() {
// do nothing - do not flush underlying stream.
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/io/ArrayManagedOutputStream.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/io/ArrayManagedOutputStream.java
index dd61448836f..f93af8d8b9b 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/io/ArrayManagedOutputStream.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/io/ArrayManagedOutputStream.java
@@ -192,7 +192,7 @@ public class ArrayManagedOutputStream extends OutputStream {
long bytesRead = 0L;
@Override
- public int read() throws IOException {
+ public int read() {
readLock.lock();
try {
if (bytesRead >= totalSize) {
@@ -215,7 +215,7 @@ public class ArrayManagedOutputStream extends OutputStream {
}
@Override
- public int read(final byte[] b, final int off, final int len)
throws IOException {
+ public int read(final byte[] b, final int off, final int len) {
readLock.lock();
try {
if (bytesRead >= totalSize) {
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/providers/local/WriteAheadLocalStateProvider.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/providers/local/WriteAheadLocalStateProvider.java
index 1babf959422..4950986626d 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/providers/local/WriteAheadLocalStateProvider.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/providers/local/WriteAheadLocalStateProvider.java
@@ -281,7 +281,7 @@ public class WriteAheadLocalStateProvider extends
AbstractStateProvider {
this.alwaysSync = alwaysSync;
}
- public synchronized StateMap getState() throws IOException {
+ public synchronized StateMap getState() {
return stateMap;
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/jaxb/BulletinAdapter.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/jaxb/BulletinAdapter.java
index b4c66650bf8..739a620f816 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/jaxb/BulletinAdapter.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/jaxb/BulletinAdapter.java
@@ -25,7 +25,7 @@ import org.apache.nifi.reporting.Bulletin;
public class BulletinAdapter extends XmlAdapter<AdaptedBulletin, Bulletin> {
@Override
- public Bulletin unmarshal(final AdaptedBulletin b) throws Exception {
+ public Bulletin unmarshal(final AdaptedBulletin b) {
if (b == null) {
return null;
}
@@ -42,7 +42,7 @@ public class BulletinAdapter extends
XmlAdapter<AdaptedBulletin, Bulletin> {
}
@Override
- public AdaptedBulletin marshal(final Bulletin b) throws Exception {
+ public AdaptedBulletin marshal(final Bulletin b) {
if (b == null) {
return null;
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/protocol/http/StandardHttpFlowFileServerProtocol.java
b/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/protocol/http/StandardHttpFlowFileServerProtocol.java
index a4b4a436943..09c35fee1d2 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/protocol/http/StandardHttpFlowFileServerProtocol.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/protocol/http/StandardHttpFlowFileServerProtocol.java
@@ -57,7 +57,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- public FlowFileCodec negotiateCodec(final Peer peer) throws IOException {
+ public FlowFileCodec negotiateCodec(final Peer peer) {
return codec;
}
@@ -89,7 +89,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- protected void writeTransactionResponse(boolean isTransfer, ResponseCode
response, CommunicationsSession commsSession, String explanation) throws
IOException {
+ protected void writeTransactionResponse(boolean isTransfer, ResponseCode
response, CommunicationsSession commsSession, String explanation) {
HttpServerCommunicationsSession commSession =
(HttpServerCommunicationsSession) commsSession;
commSession.setResponseCode(response);
@@ -187,7 +187,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- protected int commitTransferTransaction(Peer peer, FlowFileTransaction
transaction) throws IOException {
+ protected int commitTransferTransaction(Peer peer, FlowFileTransaction
transaction) {
return holdTransaction(peer, transaction);
}
@@ -203,7 +203,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- protected int commitReceiveTransaction(Peer peer, FlowFileTransaction
transaction) throws IOException {
+ protected int commitReceiveTransaction(Peer peer, FlowFileTransaction
transaction) {
return holdTransaction(peer, transaction);
}
@@ -218,7 +218,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- public RequestType getRequestType(final Peer peer) throws IOException {
+ public RequestType getRequestType(final Peer peer) {
return null;
}
@@ -228,7 +228,7 @@ public class StandardHttpFlowFileServerProtocol extends
AbstractFlowFileServerPr
}
@Override
- public void sendPeerList(Peer peer, Optional<ClusterNodeInformation>
clusterNodeInfo, final NodeInformation self) throws IOException {
+ public void sendPeerList(Peer peer, Optional<ClusterNodeInformation>
clusterNodeInfo, final NodeInformation self) {
}
@Override
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessGroupAuditor.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessGroupAuditor.java
index b3be43c2c85..4ad049a1839 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessGroupAuditor.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessGroupAuditor.java
@@ -327,7 +327,7 @@ public class ProcessGroupAuditor extends NiFiAuditor {
}
}
- private List<ControllerServiceNode> getControllerServices(final String
groupId, final Collection<String> serviceIds) throws Throwable {
+ private List<ControllerServiceNode> getControllerServices(final String
groupId, final Collection<String> serviceIds) {
final ProcessGroupDAO processGroupDAO = getProcessGroupDAO();
final ProcessGroup processGroup =
processGroupDAO.getProcessGroup(groupId);
final List<ControllerServiceNode> csNodes = new ArrayList<>();
@@ -455,7 +455,7 @@ public class ProcessGroupAuditor extends NiFiAuditor {
return action;
}
- private void saveUpdateControllerServiceAction(final ControllerServiceNode
csNode, final Operation operation) throws Throwable {
+ private void saveUpdateControllerServiceAction(final ControllerServiceNode
csNode, final Operation operation) {
final FlowChangeAction action = createFlowChangeAction();
action.setSourceId(csNode.getIdentifier());
action.setSourceName(csNode.getName());
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/util/VirtualThreadParallelProcessingService.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/util/VirtualThreadParallelProcessingService.java
index 22df600d4bc..330b6bd8913 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/util/VirtualThreadParallelProcessingService.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/util/VirtualThreadParallelProcessingService.java
@@ -26,7 +26,6 @@ import org.apache.nifi.util.NiFiProperties;
import org.apache.nifi.web.controller.ControllerFacade;
import java.io.Closeable;
-import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -104,7 +103,7 @@ public class VirtualThreadParallelProcessingService
implements PredictionBasedPa
}
@Override
- public void close() throws IOException {
+ public void close() {
if (parallelProcessingExecutorService != null) {
parallelProcessingExecutorService.close();
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/configuration/WebSecurityConfiguration.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/configuration/WebSecurityConfiguration.java
index 44d0db36e3b..2f18c56292d 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/configuration/WebSecurityConfiguration.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/configuration/WebSecurityConfiguration.java
@@ -119,7 +119,7 @@ public class WebSecurityConfiguration {
final Saml2LogoutResponseFilter saml2LogoutResponseFilter,
final Saml2SingleLogoutFilter saml2SingleLogoutFilter,
final Saml2LocalLogoutFilter saml2LocalLogoutFilter
- ) throws Exception {
+ ) {
http
.logout(AbstractHttpConfigurer::disable)
.rememberMe(AbstractHttpConfigurer::disable)
diff --git
a/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
b/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
index 54a8080c8a5..a3d48708688 100644
--- a/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
+++ b/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
@@ -683,12 +683,12 @@ public class MockProcessSession implements ProcessSession
{
incrementReadCount(flowFile);
final InputStream errorHandlingStream = new InputStream() {
@Override
- public int read() throws IOException {
+ public int read() {
return bais.read();
}
@Override
- public int read(byte[] b, int off, int len) throws IOException {
+ public int read(byte[] b, int off, int len) {
return bais.read(b, off, len);
}
@@ -715,7 +715,7 @@ public class MockProcessSession implements ProcessSession {
}
@Override
- public int available() throws IOException {
+ public int available() {
return bais.available();
}
diff --git
a/nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java
b/nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java
index 21440449354..a5285a71ebd 100644
---
a/nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java
+++
b/nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java
@@ -301,7 +301,7 @@ public class StandardProcessorTestRunner implements
TestRunner {
private class RunProcessor implements Callable<Throwable> {
@Override
- public Throwable call() throws Exception {
+ public Throwable call() {
invocations.incrementAndGet();
try {
processor.onTrigger(context, sessionFactory);
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/event/EventService.java
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/event/EventService.java
index bb11daca97a..1c8a556636d 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/event/EventService.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/event/EventService.java
@@ -89,7 +89,7 @@ public class EventService implements DisposableBean {
}
@Override
- public void destroy() throws Exception {
+ public void destroy() {
LOGGER.info("Shutting down event consumer...");
this.scheduledExecutorService.shutdownNow();
LOGGER.info("Event consumer shutdown!");
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/AuthorizerFactory.java
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/AuthorizerFactory.java
index adbe443e2a2..c8bdfcc3e5d 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/AuthorizerFactory.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-framework/src/main/java/org/apache/nifi/registry/security/authorization/AuthorizerFactory.java
@@ -265,7 +265,7 @@ public class AuthorizerFactory implements
UserGroupProviderLookup, AccessPolicyP
}
@Override
- public void destroy() throws Exception {
+ public void destroy() {
authorizers.forEach((key, value) -> value.preDestruction());
accessPolicyProviders.forEach((key, value) -> value.preDestruction());
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-jetty/src/main/java/org/apache/nifi/registry/jetty/handler/ContextPathRedirectPatternRule.java
b/nifi-registry/nifi-registry-core/nifi-registry-jetty/src/main/java/org/apache/nifi/registry/jetty/handler/ContextPathRedirectPatternRule.java
index faf9260b252..765fe429993 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-jetty/src/main/java/org/apache/nifi/registry/jetty/handler/ContextPathRedirectPatternRule.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-jetty/src/main/java/org/apache/nifi/registry/jetty/handler/ContextPathRedirectPatternRule.java
@@ -23,7 +23,6 @@ import org.eclipse.jetty.rewrite.handler.Rule;
import org.eclipse.jetty.server.Response;
import org.eclipse.jetty.util.Callback;
-import java.io.IOException;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
@@ -53,7 +52,7 @@ public class ContextPathRedirectPatternRule extends
RedirectPatternRule {
}
@Override
- public Rule.Handler apply(Rule.Handler input) throws IOException {
+ public Rule.Handler apply(Rule.Handler input) {
return new Rule.Handler(input) {
@Override
protected boolean handle(Response response, Callback callback) {
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-test/src/main/java/org/apache/nifi/registry/db/MySqlDataSourceFactory.java
b/nifi-registry/nifi-registry-core/nifi-registry-test/src/main/java/org/apache/nifi/registry/db/MySqlDataSourceFactory.java
index 4e229796653..07189865cbc 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-test/src/main/java/org/apache/nifi/registry/db/MySqlDataSourceFactory.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-test/src/main/java/org/apache/nifi/registry/db/MySqlDataSourceFactory.java
@@ -22,8 +22,6 @@ import org.testcontainers.delegate.DatabaseDelegate;
import org.testcontainers.jdbc.JdbcDatabaseDelegate;
import org.testcontainers.mysql.MySQLContainer;
-import java.sql.SQLException;
-import javax.script.ScriptException;
import javax.sql.DataSource;
public abstract class MySqlDataSourceFactory extends TestDataSourceFactory {
@@ -42,7 +40,7 @@ public abstract class MySqlDataSourceFactory extends
TestDataSourceFactory {
}
@PostConstruct
- public void initDatabase() throws SQLException, ScriptException {
+ public void initDatabase() {
DatabaseDelegate databaseDelegate = new
JdbcDatabaseDelegate(mysqlContainer(), "");
databaseDelegate.execute("DROP DATABASE test; CREATE DATABASE test;",
"", 0, false, true);
}
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/api/AccessResource.java
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/api/AccessResource.java
index abe1d5f708d..04d0f5f6db5 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/api/AccessResource.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/api/AccessResource.java
@@ -653,7 +653,7 @@ public class AccessResource extends ApplicationResource {
summary = "Retrieves a JWT following a successful login sequence
using the configured OpenId Connect provider.",
description = NON_GUARANTEED_ENDPOINT
)
- public Response oidcExchange(@Context HttpServletRequest
httpServletRequest, @Context HttpServletResponse httpServletResponse) throws
Exception {
+ public Response oidcExchange(@Context HttpServletRequest
httpServletRequest, @Context HttpServletResponse httpServletResponse) {
// only consider user specific access over https
if (!httpServletRequest.isSecure()) {
throw new IllegalStateException("User authentication/authorization
is only supported when running over HTTPS.");
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/NiFiRegistrySecurityConfig.java
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/NiFiRegistrySecurityConfig.java
index 3ef56a5115b..7cba5ca1266 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/NiFiRegistrySecurityConfig.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/NiFiRegistrySecurityConfig.java
@@ -84,7 +84,7 @@ public class NiFiRegistrySecurityConfig {
private JwtIdentityProvider jwtIdentityProvider;
@Bean
- public SecurityFilterChain securityFilterChain(final HttpSecurity http)
throws Exception {
+ public SecurityFilterChain securityFilterChain(final HttpSecurity http) {
return http
.addFilterBefore(x509AuthenticationFilter(),
AnonymousAuthenticationFilter.class)
.addFilterBefore(jwtAuthenticationFilter(),
AnonymousAuthenticationFilter.class)
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/authorization/ResourceAuthorizationFilter.java
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/authorization/ResourceAuthorizationFilter.java
index 948e534aced..2f7c322c2b2 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/authorization/ResourceAuthorizationFilter.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-web-api/src/main/java/org/apache/nifi/registry/web/security/authorization/ResourceAuthorizationFilter.java
@@ -156,7 +156,7 @@ public class ResourceAuthorizationFilter extends
GenericFilterBean {
chain.doFilter(req, res);
}
- private void failedAuthorization(HttpServletRequest request,
HttpServletResponse response, FilterChain chain, Exception failure) throws
IOException, ServletException {
+ private void failedAuthorization(HttpServletRequest request,
HttpServletResponse response, FilterChain chain, Exception failure) throws
IOException {
logger.debug("Request filter authorization check failed. Blocking
access.");
NiFiUser user = NiFiUserUtils.getNiFiUser();
diff --git
a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
index ecc9aa1aaa4..55a17b75ff2 100644
---
a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
+++
b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/extensions/NexusExtensionClient.java
@@ -34,7 +34,6 @@ import java.io.ByteArrayOutputStream;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URI;
import java.net.URLEncoder;
@@ -118,7 +117,7 @@ public class NexusExtensionClient implements
ExtensionClient {
return webClientService;
}
- private String resolveUrl(final BundleCoordinate bundleCoordinate) throws
UnsupportedEncodingException {
+ private String resolveUrl(final BundleCoordinate bundleCoordinate) {
final StringBuilder sb = new StringBuilder(baseUrl);
if (!baseUrl.endsWith("/")) {
sb.append("/");
diff --git
a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/ExceptionalTriggerResult.java
b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/ExceptionalTriggerResult.java
index 8631a62fca9..bf42a922fa4 100644
---
a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/ExceptionalTriggerResult.java
+++
b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/flow/ExceptionalTriggerResult.java
@@ -20,7 +20,6 @@ package org.apache.nifi.stateless.flow;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.processor.exception.TerminatedTaskException;
-import java.io.IOException;
import java.io.InputStream;
import java.util.Collections;
import java.util.List;
@@ -65,7 +64,7 @@ public class ExceptionalTriggerResult implements
TriggerResult {
}
@Override
- public byte[] readContentAsByteArray(final FlowFile flowFile) throws
IOException {
+ public byte[] readContentAsByteArray(final FlowFile flowFile) {
throw new IllegalArgumentException("Unknown FlowFile: " + flowFile);
}
diff --git
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/MockCSVReader.java
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/MockCSVReader.java
index 777386c2287..4a48e0e06bd 100644
---
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/MockCSVReader.java
+++
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions-services/src/main/java/org/apache/nifi/cs/tests/system/MockCSVReader.java
@@ -20,7 +20,6 @@ package org.apache.nifi.cs.tests.system;
import org.apache.nifi.controller.AbstractControllerService;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.logging.ComponentLog;
-import org.apache.nifi.serialization.MalformedRecordException;
import org.apache.nifi.serialization.RecordReader;
import org.apache.nifi.serialization.RecordReaderFactory;
import org.apache.nifi.serialization.SimpleRecordSchema;
@@ -67,7 +66,7 @@ public class MockCSVReader extends AbstractControllerService
implements RecordRe
return new RecordReader() {
@Override
- public Record nextRecord(final boolean coerceTypes, final boolean
dropUnknownFields) throws IOException, MalformedRecordException {
+ public Record nextRecord(final boolean coerceTypes, final boolean
dropUnknownFields) throws IOException {
String nextLine;
final Map<String, Object> values = new HashMap<>();
diff --git
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/connectors/tests/system/AssetConnector.java
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/connectors/tests/system/AssetConnector.java
index 4b710ae53bc..05d8900ca22 100644
---
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/connectors/tests/system/AssetConnector.java
+++
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/connectors/tests/system/AssetConnector.java
@@ -70,7 +70,7 @@ public class AssetConnector extends AbstractConnector {
}
@Override
- public void prepareForUpdate(final FlowContext workingContext, final
FlowContext activeContext) throws FlowUpdateException {
+ public void prepareForUpdate(final FlowContext workingContext, final
FlowContext activeContext) {
// No-op: this connector does not manipulate the flow.
}
diff --git
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/nar/provider/LocalDirectoryNarProvider.java
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/nar/provider/LocalDirectoryNarProvider.java
index ec03a99c200..f35fd80f286 100644
---
a/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/nar/provider/LocalDirectoryNarProvider.java
+++
b/nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/nar/provider/LocalDirectoryNarProvider.java
@@ -49,7 +49,7 @@ public class LocalDirectoryNarProvider implements
ExternalResourceProvider {
}
@Override
- public Collection<ExternalResourceDescriptor> listResources() throws
IOException {
+ public Collection<ExternalResourceDescriptor> listResources() {
return Arrays.stream(sourceDir.listFiles((dir, name) ->
name.endsWith(".nar")))
.map(this::createDescriptor)
.collect(Collectors.toList());
diff --git
a/nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/java/org/apache/nifi/nar/provider/StandardClassLoaderInfoService.java
b/nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/java/org/apache/nifi/nar/provider/StandardClassLoaderInfoService.java
index ac899274a56..8f84c06dbe4 100644
---
a/nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/java/org/apache/nifi/nar/provider/StandardClassLoaderInfoService.java
+++
b/nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/java/org/apache/nifi/nar/provider/StandardClassLoaderInfoService.java
@@ -23,7 +23,6 @@ import org.apache.nifi.annotation.lifecycle.OnEnabled;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.controller.AbstractControllerService;
import org.apache.nifi.controller.ConfigurationContext;
-import org.apache.nifi.reporting.InitializationException;
import java.util.Collections;
import java.util.List;
@@ -40,11 +39,9 @@ public class StandardClassLoaderInfoService extends
AbstractControllerService im
/**
* @param context
* the configuration context
- * @throws InitializationException
- * if unable to create a database connection
*/
@OnEnabled
- public void onEnabled(final ConfigurationContext context) throws
InitializationException {
+ public void onEnabled(final ConfigurationContext context) {
}
diff --git
a/nifi-toolkit/nifi-toolkit-client/src/main/java/org/apache/nifi/toolkit/client/impl/JerseyControllerClient.java
b/nifi-toolkit/nifi-toolkit-client/src/main/java/org/apache/nifi/toolkit/client/impl/JerseyControllerClient.java
index 721e0f75ab4..24955ba9a1a 100644
---
a/nifi-toolkit/nifi-toolkit-client/src/main/java/org/apache/nifi/toolkit/client/impl/JerseyControllerClient.java
+++
b/nifi-toolkit/nifi-toolkit-client/src/main/java/org/apache/nifi/toolkit/client/impl/JerseyControllerClient.java
@@ -80,7 +80,7 @@ public class JerseyControllerClient extends
AbstractJerseyClient implements Cont
}
@Override
- public FlowRegistryClientEntity getRegistryClient(final String id) throws
NiFiClientException, IOException {
+ public FlowRegistryClientEntity getRegistryClient(final String id) {
if (StringUtils.isBlank(id)) {
throw new IllegalArgumentException("Registry client id cannot be
null");
}
