[flink] branch master updated: [FLINK-11001] [table] Update exception message for time attributes on aliases

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr 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 038dc00  [FLINK-11001] [table] Update exception message for time attributes on aliases
038dc00 is described below

commit 038dc0008f7b27c787e3ccba2204f3a2851dff7d
Author: Timo Walther <tw...@apache.org>
AuthorDate: Fri Jan 4 15:46:06 2019 +0100

    [FLINK-11001] [table] Update exception message for time attributes on aliases
---
 .../scala/org/apache/flink/table/api/StreamTableEnvironment.scala    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
index 4fa501c..e0d3269 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
@@ -683,9 +683,8 @@ abstract class StreamTableEnvironment(
       case (Alias(UnresolvedFieldReference(_), name, _), _) => fieldNames = name :: fieldNames
 
       case (e, _) =>
-        throw new TableException(s"Time attributes can only be defined on field references or " +
-          s"aliases of valid field references. Rowtime attributes can replace existing fields, " +
-          s"proctime attributes can not. " +
+        throw new TableException(s"Time attributes can only be defined on field references. " +
+          s"Rowtime attributes can replace existing fields, proctime attributes can not. " +
           s"But was: $e")
     }