Repository: flink Updated Branches: refs/heads/master 3f1e8b915 -> 5d2c465af
[hotfix] Fix exception message Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d2c465a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5d2c465a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5d2c465a Branch: refs/heads/master Commit: 5d2c465afdf1f2e4f630568435c69e1668a184c1 Parents: 3f1e8b9 Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 17:08:58 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Aug 2 17:08:58 2016 +0200 ---------------------------------------------------------------------- .../scala/org/apache/flink/api/table/plan/logical/operators.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5d2c465a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala index 381244e..ad8618c 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala @@ -144,7 +144,7 @@ case class Sort(order: Seq[Ordering], child: LogicalNode) extends UnaryNode { override def validate(tableEnv: TableEnvironment): LogicalNode = { if (tableEnv.isInstanceOf[StreamTableEnvironment]) { - failValidation(s"Distinct on stream tables is currently not supported.") + failValidation(s"Sort on stream tables is currently not supported.") } super.validate(tableEnv) }