Repository: flink Updated Branches: refs/heads/master eb525b7f8 -> ce04965b6
[hotfix][table] Fix misleading exception message This closes #6163. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aa2029c4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aa2029c4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aa2029c4 Branch: refs/heads/master Commit: aa2029c4c00d7480adac1019bbe3f86944245632 Parents: fd72b4e Author: blueszheng <[email protected]> Authored: Thu Jun 14 17:37:14 2018 +0800 Committer: zentol <[email protected]> Committed: Wed Jun 27 22:01:16 2018 +0200 ---------------------------------------------------------------------- .../scala/org/apache/flink/table/plan/logical/groupWindows.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/aa2029c4/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/groupWindows.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/groupWindows.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/groupWindows.scala index 4a8fb52..31d8b4a 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/groupWindows.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/groupWindows.scala @@ -59,7 +59,7 @@ case class TumblingGroupWindow( case _: BatchTableEnvironment if !(isTimePoint(timeField.resultType) || isLong(timeField.resultType)) => ValidationFailure( - "Tumbling window expects a time attribute for grouping in a stream environment.") + "Tumbling window expects a time attribute for grouping in a batch environment.") // check row intervals on event-time case _: StreamTableEnvironment
