[flink] branch master updated: [FLINK-11173][table] Fix the exception message of proctime attribute validation in TableSourceUtil#validateTableSource

[twalthr]

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 c09dc96  [FLINK-11173][table] Fix the exception message of proctime 
attribute validation in TableSourceUtil#validateTableSource
c09dc96 is described below

commit c09dc96a460a4947a348639c10d52ed56360fb96
Author: wenhuitang <wenhui_t...@yeah.net>
AuthorDate: Tue Dec 25 20:16:27 2018 +0800

    [FLINK-11173][table] Fix the exception message of proctime attribute 
validation in TableSourceUtil#validateTableSource
    
    This closes #7374.
---
 .../scala/org/apache/flink/table/sources/TableSourceUtil.scala    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala
 
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala
index 15d6890..998fc1f 100644
--- 
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala
+++ 
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala
@@ -114,12 +114,12 @@ object TableSourceUtil {
           val rowtimeIdx = schema.getFieldNames.indexOf(rowtimeAttribute)
           // ensure that field exists
           if (rowtimeIdx < 0) {
-            throw new ValidationException(s"Found a RowtimeAttributeDescriptor 
for field " +
+            throw new ValidationException(s"Found a rowtime attribute for 
field " +
               s"'$rowtimeAttribute' but field '$rowtimeAttribute' does not 
exist in table.")
           }
           // ensure that field is of type TIMESTAMP
           if (schema.getFieldTypes()(rowtimeIdx) != Types.SQL_TIMESTAMP) {
-            throw new ValidationException(s"Found a RowtimeAttributeDescriptor 
for field " +
+            throw new ValidationException(s"Found a rowtime attribute for 
field " +
               s"'$rowtimeAttribute' but field '$rowtimeAttribute' is not of 
type TIMESTAMP.")
           }
           // look up extractor input fields in return type
@@ -138,12 +138,12 @@ object TableSourceUtil {
         val proctimeIdx = schema.getFieldNames.indexOf(proctimeAttribute)
         // ensure that field exists
         if (proctimeIdx < 0) {
-          throw new ValidationException(s"Found a RowtimeAttributeDescriptor 
for field " +
+          throw new ValidationException(s"Found a processing time attribute 
for field " +
             s"'$proctimeAttribute' but field '$proctimeAttribute' does not 
exist in table.")
         }
         // ensure that field is of type TIMESTAMP
         if (schema.getFieldTypes()(proctimeIdx) != Types.SQL_TIMESTAMP) {
-          throw new ValidationException(s"Found a RowtimeAttributeDescriptor 
for field " +
+          throw new ValidationException(s"Found a processing time attribute 
for field " +
             s"'$proctimeAttribute' but field '$proctimeAttribute' is not of 
type TIMESTAMP.")
         }
       case _ => // nothing to validate