Skip to content

Commit

Permalink
[hotfix][doc] fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
JingGe authored and dawidwys committed Feb 10, 2022
1 parent 4fda4c6 commit 0de9898
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -481,7 +481,7 @@ public CheckpointConfig getCheckpointConfig() {
* <p>The job draws checkpoints periodically, in the given interval. The state will be stored in
* the configured state backend.
*
* <p>NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment.
* <p>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.
Expand All @@ -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.
*
* <p>NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment.
* <p>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.
Expand All @@ -525,7 +525,7 @@ public StreamExecutionEnvironment enableCheckpointing(long interval, Checkpointi
* <p>The job draws checkpoints periodically, in the given interval. The state will be stored in
* the configured state backend.
*
* <p>NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment.
* <p>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.
Expand Down Expand Up @@ -555,7 +555,7 @@ public StreamExecutionEnvironment enableCheckpointing(
* <p>The job draws checkpoints periodically, in the default interval. The state will be stored
* in the configured state backend.
*
* <p>NOTE: Checkpointing iterative streaming dataflows in not properly supported at the moment.
* <p>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.
Expand Down Expand Up @@ -1140,7 +1140,7 @@ public final <OUT> DataStreamSource<OUT> 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
Expand Down

0 comments on commit 0de9898

Please sign in to comment.