http://git-wip-us.apache.org/repos/asf/flink/blob/68605d05/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java index 2175fb5..1be9650 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java @@ -24,6 +24,10 @@ import org.apache.flink.api.common.functions.ReduceFunction; import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.api.java.functions.KeySelector; +/** + * @deprecated Deprecated in favour of the generic {@link WindowOperator}. This was an + * optimized implementation used for aligned windows. + */ @Internal @Deprecated public class AggregatingProcessingTimeWindowOperator<KEY, IN>
http://git-wip-us.apache.org/repos/asf/flink/blob/68605d05/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---------------------------------------------------------------------- diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java index 863b442..f4557c9 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java @@ -105,6 +105,12 @@ public class FlinkYarnSessionCli implements CustomCommandLine<YarnClusterClient> private final Option SLOTS; private final Option DETACHED; private final Option ZOOKEEPER_NAMESPACE; + + /** + * @deprecated Streaming mode has been deprecated without replacement. Set the + * {@link ConfigConstants#TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY} configuration + * key to true to get the previous batch mode behaviour. + */ @Deprecated private final Option STREAMING; private final Option NAME; http://git-wip-us.apache.org/repos/asf/flink/blob/68605d05/tools/maven/checkstyle.xml ---------------------------------------------------------------------- diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml index b8f1b1a..00e173b 100644 --- a/tools/maven/checkstyle.xml +++ b/tools/maven/checkstyle.xml @@ -124,6 +124,8 @@ under the License. <module name="FileContentsHolder"/> + <module name="MissingDeprecated"/> + <!-- <module name="ConstantName" /> <module name="LocalFinalVariableName" /> <module name="LocalVariableName" />
