This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1c82ee479ebbb1dc41cc06a7eb8144d76ca1013a Author: Aljoscha Krettek <[email protected]> AuthorDate: Thu Dec 17 10:22:10 2020 +0100 [hotfix] Make SimpleTransformationTranslator methods final They should not be overridden, subclasses are meant to implement the "internal" methods. --- .../flink/streaming/api/graph/SimpleTransformationTranslator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/SimpleTransformationTranslator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/SimpleTransformationTranslator.java index 186a5e8..762d103 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/SimpleTransformationTranslator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/SimpleTransformationTranslator.java @@ -39,7 +39,7 @@ public abstract class SimpleTransformationTranslator<OUT, T extends Transformati implements TransformationTranslator<OUT, T> { @Override - public Collection<Integer> translateForBatch(final T transformation, final Context context) { + public final Collection<Integer> translateForBatch(final T transformation, final Context context) { checkNotNull(transformation); checkNotNull(context); @@ -51,7 +51,7 @@ public abstract class SimpleTransformationTranslator<OUT, T extends Transformati } @Override - public Collection<Integer> translateForStreaming(final T transformation, final Context context) { + public final Collection<Integer> translateForStreaming(final T transformation, final Context context) { checkNotNull(transformation); checkNotNull(context);
