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 <zoud...@163.com> AuthorDate: Mon Sep 14 19:33:24 2020 +0800 [hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver (#12672) Co-authored-by: zoudan <zou...@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