diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/Stateful.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/Stateful.java index 2303e64275..f352596c73 100644 --- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/Stateful.java +++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/Stateful.java @@ -44,15 +44,11 @@ import org.apache.nifi.components.state.StateManager; public @interface Stateful { /** * Provides a description of what information is being stored in the {@link StateManager} - * - * @return a description of what information is being stored in the {@link StateManager} */ String description(); /** * Indicates the Scope(s) associated with the State that is stored and retrieved. - * - * @return */ Scope[]scopes(); } diff --git a/nifi-api/src/main/java/org/apache/nifi/components/state/StateManager.java b/nifi-api/src/main/java/org/apache/nifi/components/state/StateManager.java index 0c0e867232..7ff8cecaa3 100644 --- a/nifi-api/src/main/java/org/apache/nifi/components/state/StateManager.java +++ b/nifi-api/src/main/java/org/apache/nifi/components/state/StateManager.java @@ -69,8 +69,8 @@ public interface StateManager { * If the state has not yet been set, the StateMap's version will be -1, and the map of values will be empty. * * @param scope the scope to use when fetching the state - * @return - * @throws IOException + * @return the current state for the component + * @throws IOException if unable to communicate with the underlying storage mechanism */ StateMap getState(Scope scope) throws IOException; diff --git a/nifi-api/src/main/java/org/apache/nifi/components/state/StateMap.java b/nifi-api/src/main/java/org/apache/nifi/components/state/StateMap.java index 7984e42a59..4d67164fa4 100644 --- a/nifi-api/src/main/java/org/apache/nifi/components/state/StateMap.java +++ b/nifi-api/src/main/java/org/apache/nifi/components/state/StateMap.java @@ -35,7 +35,7 @@ public interface StateMap { /** * Returns the value associated with the given key - * + * * @param key the key whose value should be retrieved * @return the value associated with the given key, or null if no value is associated * with this key. diff --git a/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java b/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java index 5d867b7642..d0c5b46de6 100644 --- a/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java +++ b/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java @@ -25,7 +25,6 @@ import java.util.Map; import java.util.Set; import java.util.regex.Pattern; -import org.apache.nifi.components.state.StateManager; import org.apache.nifi.controller.queue.QueueSize; import org.apache.nifi.flowfile.FlowFile; import org.apache.nifi.processor.exception.FlowFileAccessException; diff --git a/nifi-docs/src/main/asciidoc/administration-guide.adoc b/nifi-docs/src/main/asciidoc/administration-guide.adoc index 4f306866f3..23327e2255 100644 --- a/nifi-docs/src/main/asciidoc/administration-guide.adoc +++ b/nifi-docs/src/main/asciidoc/administration-guide.adoc @@ -548,6 +548,11 @@ We can initialize our Kerberos ticket by running the following command: [source] kinit nifi +Note, the above `kinit` command requires that Kerberos client libraries be installed. This is accomplished in Fedora-based Linux distributions via: + +[source] +yum install krb5-workstation krb5-libs krb5-auth-dialog + Now, when we start NiFi, it will use Kerberos to authentication as the `nifi` user when communicating with ZooKeeper. 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 ddc1e713c1..29d31d60e1 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 @@ -798,8 +798,8 @@ public class StandardProcessorTestRunner implements TestRunner { /** * Returns the State Manager for the given Controller Service. * - * @param controllerService - * @return + * @param controllerService the Controller Service whose State Manager should be returned + * @return the State Manager for the given Controller Service */ @Override public MockStateManager getStateManager(final ControllerService controllerService) { diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ConfiguredComponent.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ConfiguredComponent.java index 7e497002cc..87acb858c1 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ConfiguredComponent.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ConfiguredComponent.java @@ -36,7 +36,7 @@ public interface ConfiguredComponent { /** * Sets the property with the given name to the given value - * + * * @param name the name of the property to update * @param value the value to update the property to * @param triggerOnPropertyModified if true, will trigger the #onPropertyModified method of the component diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/logging/LogRepository.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/logging/LogRepository.java index 6e1311a76e..54bb6720d4 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/logging/LogRepository.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/logging/LogRepository.java @@ -67,7 +67,7 @@ public interface LogRepository { /** * Sets the current logger for the component - * + * * @param logger the logger to use */ void setLogger(ComponentLog logger); diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java index ee764e6371..ef27fb5708 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/scheduling/StandardProcessScheduler.java @@ -122,7 +122,7 @@ public final class StandardProcessScheduler implements ProcessScheduler { /** * Submits the given task to be executed exactly once in a background thread - * + * * @param task the task to perform */ public void submitFrameworkTask(final Runnable task) { diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/HDFSListing.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/HDFSListing.java index 27040bf010..6786945d2b 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/HDFSListing.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/util/HDFSListing.java @@ -89,9 +89,9 @@ public class HDFSListing { } /** - * Converts this HDFSListing into a Map so that it can be stored in a StateManager. + * Converts this HDFSListing into a Map<String, String> so that it can be stored in a StateManager. * - * @return a Map that represents the same information as this HDFSListing + * @return a Map that represents the same information as this HDFSListing */ public Map toMap() { final Map map = new HashMap<>(1 + matchingPaths.size()); diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java index 6f99b42581..f992978558 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java @@ -192,7 +192,7 @@ public class TailFile extends AbstractProcessor { * Recovers values for the State that was stored in a local file. * * @param context the ProcessContext that indicates where the state is stored - * @return a Map that contains the keys defined in {@link TailFileState.StateKeys} + * @return a Map that contains the keys defined in {@link TailFileState.StateKeys} * @throws IOException if the state file exists but was unable to be read */ private Map recoverStateValuesFromFile(final ProcessContext context) throws IOException {