You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/09/14 11:33:58 UTC
[flink] branch master updated: [hotfix][typo] fix typos in
ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver (#12672)
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9b0fb56 [hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver (#12672)
9b0fb56 is described below
commit 9b0fb562898b809b860cf0065ded7a45c49300af
Author: zoudan <zo...@163.com>
AuthorDate: Mon Sep 14 19:33:24 2020 +0800
[hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver (#12672)
Co-authored-by: zoudan <zo...@bytedance.com>
---
.../apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala | 2 +-
.../runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
index 7cffabe..f19a4a3 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
@@ -102,7 +102,7 @@ class ProcTimeBoundedRangeOver[K](
// add current element to the window list of elements with corresponding timestamp
var rowList = rowMapState.get(currentTime)
- // null value means that this si the first event received for this timestamp
+ // null value means that this is the first event received for this timestamp
if (rowList == null) {
rowList = new ArrayList[Row]()
// register timer to process event once the current millisecond passed
diff --git a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java
index 0d4dcf4..e6527e8 100644
--- a/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java
+++ b/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java
@@ -124,7 +124,7 @@ public class ProcTimeRangeBoundedPrecedingFunction<K> extends KeyedProcessFuncti
// add current element to the window list of elements with corresponding timestamp
List<RowData> rowList = inputState.get(currentTime);
- // null value means that this si the first event received for this timestamp
+ // null value means that this is the first event received for this timestamp
if (rowList == null) {
rowList = new ArrayList<RowData>();
// register timer to process event once the current millisecond passed