diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java index 35850eacd0648..ea52c5b8a4183 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java @@ -264,7 +264,7 @@ public StreamExecutionEnvironment( userClassloader == null ? getClass().getClassLoader() : userClassloader; // the configuration of a job or an operator can be specified at the following places: - // i) at the operator level using e.g. parallelism using the + // i) at the operator level via e.g. parallelism by using the // SingleOutputStreamOperator.setParallelism(). // ii) programmatically by using e.g. the env.setRestartStrategy() method // iii) in the configuration passed here @@ -481,7 +481,7 @@ public CheckpointConfig getCheckpointConfig() { *

The job draws checkpoints periodically, in the given interval. The state will be stored in * the configured state backend. * - *

NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment. + *

NOTE: Checkpointing iterative streaming dataflows is not properly supported at the moment. * For that reason, iterative jobs will not be started if used with enabled checkpointing. To * override this mechanism, use the {@link #enableCheckpointing(long, CheckpointingMode, * boolean)} method. @@ -502,7 +502,7 @@ public StreamExecutionEnvironment enableCheckpointing(long interval) { * {@link CheckpointingMode} for the checkpointing ("exactly once" vs "at least once"). The * state will be stored in the configured state backend. * - *

NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment. + *

NOTE: Checkpointing iterative streaming dataflows is not properly supported at the moment. * For that reason, iterative jobs will not be started if used with enabled checkpointing. To * override this mechanism, use the {@link #enableCheckpointing(long, CheckpointingMode, * boolean)} method. @@ -525,7 +525,7 @@ public StreamExecutionEnvironment enableCheckpointing(long interval, Checkpointi *

The job draws checkpoints periodically, in the given interval. The state will be stored in * the configured state backend. * - *

NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment. + *

NOTE: Checkpointing iterative streaming dataflows is not properly supported at the moment. * If the "force" parameter is set to true, the system will execute the job nonetheless. * * @param interval Time interval between state checkpoints in millis. @@ -555,7 +555,7 @@ public StreamExecutionEnvironment enableCheckpointing( *

The job draws checkpoints periodically, in the default interval. The state will be stored * in the configured state backend. * - *

NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment. + *

NOTE: Checkpointing iterative streaming dataflows is not properly supported at the moment. * For that reason, iterative jobs will not be started if used with enabled checkpointing. To * override this mechanism, use the {@link #enableCheckpointing(long, CheckpointingMode, * boolean)} method. @@ -1140,7 +1140,7 @@ public final DataStreamSource fromElements(OUT... data) { } /** - * Creates a new data set that contains the given elements. The framework will determine the + * Creates a new data stream that contains the given elements. The framework will determine the * type according to the based type user supplied. The elements should be the same or be the * subclass to the based type. The sequence of elements must not be empty. Note that this * operation will result in a non-parallel data stream source, i.e. a data stream source with a