From 5d2c465afdf1f2e4f630568435c69e1668a184c1 Mon Sep 17 00:00:00 2001 From: twalthr Date: Tue, 2 Aug 2016 17:08:58 +0200 Subject: [PATCH] [hotfix] Fix exception message --- .../org/apache/flink/api/table/plan/logical/operators.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 381244e1829..ad8618ccf32 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) } -- GitLab