Repository: flink Updated Branches: refs/heads/release-1.5 d8ad69fc8 -> 7da268cf2
[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/7da268cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7da268cf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7da268cf Branch: refs/heads/release-1.5 Commit: 7da268cf2b2347b2a883212c7a497f63e2aac58e Parents: 583e8a1 Author: blueszheng <[email protected]> Authored: Thu Jun 14 17:37:14 2018 +0800 Committer: zentol <[email protected]> Committed: Wed Jun 27 22:01:27 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/7da268cf/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
