diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy index 134af9a8b4c1..4c5c8e8818b0 100644 --- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy +++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy @@ -1555,7 +1555,6 @@ class BeamModulePlugin implements Plugin { "JavaTimeDefaultTimeZone", "JavaUtilDate", "JodaConstructors", - "MalformedInlineTag", "MixedMutabilityReturnType", "PreferJavaTimeOverload", "NonCanonicalType", diff --git a/runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java index dca2f3075aa0..5c0780b8f83f 100644 --- a/runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java +++ b/runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java @@ -596,9 +596,9 @@ DoFnRunner createBufferingDoFnRunnerIfNeeded( } /** - * Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @} - * RequiresStableInput} functionality. By default this is the default keyed backend, but can be - * override in @{link ExecutableStageDoFnOperator}. + * Retrieve a keyed state backend that should be used to buffer elements for + * {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but + * can be override in {@link ExecutableStageDoFnOperator}. * * @return the keyed backend to use for element buffering */ diff --git a/runners/flink/2.0/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/2.0/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java index f83e719ed0b9..a4df72485cc0 100644 --- a/runners/flink/2.0/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java +++ b/runners/flink/2.0/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java @@ -596,9 +596,9 @@ DoFnRunner createBufferingDoFnRunnerIfNeeded( } /** - * Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @} - * RequiresStableInput} functionality. By default this is the default keyed backend, but can be - * override in @{link ExecutableStageDoFnOperator}. + * Retrieve a keyed state backend that should be used to buffer elements for + * {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but + * can be override in {@link ExecutableStageDoFnOperator}. * * @return the keyed backend to use for element buffering */ diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java index 2bf0d40cd5f2..a8e140b8a2c5 100644 --- a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java +++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java @@ -598,9 +598,9 @@ DoFnRunner createBufferingDoFnRunnerIfNeeded( } /** - * Retrieve a keyed state backend that should be used to buffer elements for {@link @{code @} - * RequiresStableInput} functionality. By default this is the default keyed backend, but can be - * override in @{link ExecutableStageDoFnOperator}. + * Retrieve a keyed state backend that should be used to buffer elements for + * {@code @RequiresStableInput} functionality. By default this is the default keyed backend, but + * can be override in {@link ExecutableStageDoFnOperator}. * * @return the keyed backend to use for element buffering */ diff --git a/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java b/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java index 8d978a399421..7c1b8c6bcf8c 100644 --- a/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java +++ b/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java @@ -240,7 +240,7 @@ default WindowByBuilder combineBy(CombineFunctionWithIdentity combineBy( diff --git a/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java b/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java index 7e10792826b3..763550bf6e13 100644 --- a/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java +++ b/sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java @@ -192,7 +192,7 @@ default WindowByBuilder combineBy( * Syntactic sugar to enable #combineBy to take only single argument and be used in helpers like * #combineBy(Sums.ofLongs()). * - * @deprecated Replaced by @{link #combineBy(ReduceByKey.CombineFunctionWithIdentity)}. + * @deprecated Replaced by {@link #combineBy(ReduceByKey.CombineFunctionWithIdentity)}. */ @Deprecated default WindowByBuilder combineBy( diff --git a/sdks/java/extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/SumsTest.java b/sdks/java/extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/SumsTest.java index 80480adbaa83..9948d6c37c6f 100644 --- a/sdks/java/extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/SumsTest.java +++ b/sdks/java/extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/SumsTest.java @@ -25,7 +25,7 @@ import org.junit.runner.RunWith; import org.junit.runners.JUnit4; -/** Test suite for @{link Sums}. */ +/** Test suite for {@link Sums}. */ @RunWith(JUnit4.class) public class SumsTest { diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java index be1b03105c3d..22e4547e8ed1 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java @@ -20,7 +20,7 @@ import java.io.Serializable; /** - * Provided by user and called within {@link org.apache.beam.sdk.transforms.DoFn.Setup} and @{link + * Provided by user and called within {@link org.apache.beam.sdk.transforms.DoFn.Setup} and {@link * org.apache.beam.sdk.transforms.DoFn.Teardown} lifecycle methods of {@link Call}'s {@link * org.apache.beam.sdk.transforms.DoFn}. */ diff --git a/sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/BundleSplitter.java b/sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/BundleSplitter.java index 3195e8a6dae2..830d577bfa6a 100644 --- a/sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/BundleSplitter.java +++ b/sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/BundleSplitter.java @@ -24,7 +24,7 @@ import java.util.List; import org.apache.beam.sdk.io.range.OffsetRange; -/** Determines bundle sizes based on @{link SyntheticSourceOptions}. */ +/** Determines bundle sizes based on {@link SyntheticSourceOptions}. */ public class BundleSplitter implements Serializable { private SyntheticSourceOptions options;