Fixing javadocs missing annotations

Author: rodmeneses

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java

@@ -238,6 +238,7 @@ public FlinkOperatorConfiguration getOperatorConfiguration(
      *
      * @param baseConfMap The configuration map that should be searched for relevant Flink version
      *     prefixes.
+     * @param flinkVersion The FlinkVersion to be used
      * @return A list of relevant Flink version prefixes in order of ascending Flink version.
      */
     protected static List<String> getRelevantVersionPrefixes(
@@ -381,6 +382,7 @@ private void applyConfigsFromCurrentSpec(
      * Get configuration for interacting with session jobs. Similar to the observe configuration for
      * FlinkDeployments.
      *
+     * @param name The name of the job
      * @param deployment FlinkDeployment for the session cluster
      * @param sessionJobSpec Session job spec
      * @return Session job config

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/mutator/FlinkResourceMutator.java

@@ -31,6 +31,7 @@ public interface FlinkResourceMutator extends Plugin {
      * Mutate deployment and return the mutated Object.
      *
      * @param deployment A Flink application or session cluster deployment.
+     * @return the mutated Flink application or session cluster deployment.
      */
     FlinkDeployment mutateDeployment(FlinkDeployment deployment);
 
@@ -39,13 +40,15 @@ public interface FlinkResourceMutator extends Plugin {
      *
      * @param sessionJob the session job to be mutated.
      * @param session the target session cluster of the session job to be Mutated.
+     * @return the mutated session job.
      */
     FlinkSessionJob mutateSessionJob(FlinkSessionJob sessionJob, Optional<FlinkDeployment> session);
 
     /**
      * Mutate snapshot and return the mutated Object.
      *
      * @param stateSnapshot the snapshot to be mutated.
+     * @return the mutated snapshot.
      */
     FlinkStateSnapshot mutateStateSnapshot(FlinkStateSnapshot stateSnapshot);
 }

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/AbstractFlinkResourceObserver.java

@@ -107,6 +107,7 @@ protected boolean isResourceReadyToBeObserved(FlinkResourceContext<CR> ctx) {
      * DEPLOYED state.
      *
      * @param ctx Context for resource.
+     * @return true if the resource was already upgraded, false otherwise.
      */
     protected abstract boolean checkIfAlreadyUpgraded(FlinkResourceContext<CR> ctx);
 }

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/SnapshotTriggerTimestampStore.java

@@ -53,6 +53,7 @@ public class SnapshotTriggerTimestampStore {
      * updated with this value.
      *
      * @param resource Flink resource
+     * @param snapshotType the snapshot type
      * @param snapshotsSupplier supplies related snapshot resources
      * @return instant of last trigger
      */
@@ -103,6 +104,7 @@ public Instant getLastPeriodicTriggerInstant(
      * Updates the time a periodic snapshot was last triggered for this resource.
      *
      * @param resource Kubernetes resource
+     * @param snapshotType the snapshot type
      * @param instant new timestamp
      */
     public void updateLastPeriodicTriggerTimestamp(

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java

@@ -954,7 +954,15 @@ private void deleteJar(Configuration conf, String jarId) {
         }
     }
 
-    /** Wait until Deployment is removed, return remaining timeout. */
+    /**
+     * Wait until Deployment is removed, return remaining timeout.
+     *
+     * @param name name of the deployment
+     * @param deployment The deployment resource
+     * @param propagation DeletePropagation
+     * @param timeout Timeout to wait
+     * @return remaining timeout after deletion
+     */
     @VisibleForTesting
     protected Duration deleteDeploymentBlocking(
             String name,

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventRecorder.java

@@ -122,10 +122,16 @@ public boolean triggerEvent(
     }
 
     /**
+     * @param resource The resource
+     * @param type The type
+     * @param reason the reason
+     * @param message the message
+     * @param component the component
+     * @param messageKey the message key
+     * @param client the client
      * @param interval Interval for dedupe. Null mean no dedupe.
-     * @return
      */
-    public boolean triggerEventWithInterval(
+    public void triggerEventWithInterval(
             AbstractFlinkResource<?, ?> resource,
             Type type,
             String reason,
@@ -134,7 +140,7 @@ public boolean triggerEventWithInterval(
             String messageKey,
             KubernetesClient client,
             @Nullable Duration interval) {
-        return EventUtils.createOrUpdateEventWithInterval(
+        EventUtils.createOrUpdateEventWithInterval(
                 client,
                 resource,
                 type,
@@ -166,12 +172,18 @@ public boolean triggerEventOnce(
     }
 
     /**
+     * @param resource The resource
+     * @param type The type
+     * @param reason the reason
+     * @param message the message
+     * @param component the component
+     * @param messageKey the message key
+     * @param client the client
      * @param interval Interval for dedupe. Null mean no dedupe.
      * @param dedupePredicate Predicate for dedupe algorithm..
      * @param labels Labels to store in meta data for dedupe. Do nothing if null.
-     * @return
      */
-    public boolean triggerEventWithLabels(
+    public void triggerEventWithLabels(
             AbstractFlinkResource<?, ?> resource,
             Type type,
             String reason,
@@ -182,7 +194,7 @@ public boolean triggerEventWithLabels(
             @Nullable Duration interval,
             @Nullable Predicate<Map<String, String>> dedupePredicate,
             @Nullable Map<String, String> labels) {
-        return EventUtils.createOrUpdateEventWithLabels(
+        EventUtils.createOrUpdateEventWithLabels(
                 client,
                 resource,
                 type,

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ExceptionUtils.java

@@ -30,6 +30,12 @@ public class ExceptionUtils {
     /**
      * Based on the flink ExceptionUtils#findThrowableSerializedAware but fixes an infinite loop bug
      * resulting from SerializedThrowable deserialization errors.
+     *
+     * @param throwable the throwable to be processed
+     * @param searchType the type of the exception to search for
+     * @param classLoader the classloader to use for deserialization
+     * @param <T> the exception type
+     * @return the found exception, or empty if it is not found.
      */
     public static <T extends Throwable> Optional<T> findThrowableSerializedAware(
             Throwable throwable, Class<T> searchType, ClassLoader classLoader) {
@@ -65,8 +71,8 @@ public static <T extends Throwable> Optional<T> findThrowableSerializedAware(
      * exceptions in the hierarchy.
      *
      * @param throwable the throwable to be processed
-     * @return the exception message, which will have a format similar to "cause1 -> cause2 ->
-     *     cause3"
+     * @return the exception message, which will have a format similar to "cause1 &rarr; cause2
+     *     &rarr; cause3"
      */
     public static String getExceptionMessage(Throwable throwable) {
         return getExceptionMessage(throwable, 0);

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/SnapshotUtils.java

@@ -134,6 +134,7 @@ public static SnapshotStatus getLastSnapshotStatus(
      * @param resource The resource to be snapshotted.
      * @param conf The observe configuration of the resource.
      * @param snapshotType The type of the snapshot.
+     * @param lastTrigger the last time the snapshot was triggered.
      * @return An optional {@link SnapshotTriggerType}.
      */
     @VisibleForTesting

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/StatusRecorder.java

@@ -85,6 +85,7 @@ public void notifyListeners(CR resource, STATUS prevStatus) {
      * operator behavior.
      *
      * @param resource Resource for which status update should be performed
+     * @param client Kubernetes client to use for the update
      */
     @SneakyThrows
     public void patchAndCacheStatus(CR resource, KubernetesClient client) {

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/FlinkResourceValidator.java

@@ -50,6 +50,7 @@ Optional<String> validateSessionJob(
      * Validate and return optional error.
      *
      * @param savepoint the savepoint to be validated.
+     * @param target the target resource of the savepoint to be validated.
      * @return Optional error string, should be present iff validation resulted in an error
      */
     Optional<String> validateStateSnapshot(