[hotfix][doc] fix typo of 'note that' and 'now that'

flink-core/src/main/java/org/apache/flink/api/common/state/CheckpointListener.java

@@ -117,7 +117,7 @@ public interface CheckpointListener {
  *
  * @param checkpointId The ID of the checkpoint that has been completed.
  * @throws Exception This method can propagate exceptions, which leads to a failure/recovery for
- * the task. Not that this will NOT lead to the checkpoint being revoked.
+ * the task. Note that this will NOT lead to the checkpoint being revoked.
  */
  void notifyCheckpointComplete(long checkpointId) throws Exception;
 

flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/BinaryOperatorTestBase.java

@@ -287,7 +287,7 @@ public void cancel() throws Exception {
  this.running = false;
 
  // compensate for races, where cancel is called before the driver is set
- // not that this is an artifact of a bad design of this test base, where the setup
+ // note that this is an artifact of a bad design of this test base, where the setup
  // of the basic properties is not separated from the invocation of the execution logic
  while (this.driver == null) {
  Thread.sleep(200);

flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DriverTestBase.java

@@ -294,7 +294,7 @@ public void cancel() throws Exception {
  this.running = false;
 
  // compensate for races, where cancel is called before the driver is set
- // not that this is an artifact of a bad design of this test base, where the setup
+ // note that this is an artifact of a bad design of this test base, where the setup
  // of the basic properties is not separated from the invocation of the execution logic
  while (this.driver == null) {
  Thread.sleep(200);

flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/StateChangeLogger.java

@@ -28,7 +28,7 @@
  * Logs changes to a state created by {@link ChangelogKeyedStateBackend}. The changes are intended
  * to be stored durably, included into a checkpoint and replayed on recovery in case of failure.
  *
- * <p>Not that the order of updating the delegated state and logging it using this class usually
+ * <p>Note that the order of updating the delegated state and logging it using this class usually
  * doesn't matter. However in some cases an already updated state needs to be logged. Besides that,
  * delegated state update is usually local and would fail faster. Therefore, consider updating the
  * delegated state first and logging the change second.

flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamUtils.java

@@ -122,7 +122,7 @@ public static <E> List<E> collectUnboundedStream(
  final ClientAndIterator<E> clientAndIterator = collectWithClient(stream, jobName);
  final List<E> result = collectRecordsFromUnboundedStream(clientAndIterator, numElements);
 
- // cancel the job not that we have received enough elements
+ // cancel the job now that we have received enough elements
  clientAndIterator.client.cancel().get();
 
  return result;

flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala

@@ -395,7 +395,7 @@ class AllWindowedStream[T, W <: Window](javaStream: JavaAllWStream[T, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The process window function.
@@ -416,7 +416,7 @@ class AllWindowedStream[T, W <: Window](javaStream: JavaAllWStream[T, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The window function.
@@ -436,7 +436,7 @@ class AllWindowedStream[T, W <: Window](javaStream: JavaAllWStream[T, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The window function.

flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala

@@ -374,7 +374,7 @@ class WindowedStream[T, K, W <: Window](javaStream: JavaWStream[T, K, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The window function.
@@ -394,7 +394,7 @@ class WindowedStream[T, K, W <: Window](javaStream: JavaWStream[T, K, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The window function.
@@ -413,7 +413,7 @@ class WindowedStream[T, K, W <: Window](javaStream: JavaWStream[T, K, W]) {
  * evaluation of the window for each key individually. The output of the window function is
  * interpreted as a regular non-windowed stream.
  *
- * Not that this function requires that all data in the windows is buffered until the window
+ * Note that this function requires that all data in the windows is buffered until the window
  * is evaluated, as the function provides no means of pre-aggregation.
  *
  * @param function The window function.