This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.7 by this push:
new e2daaaa [FLINK-11173][table] Fix the exception message of proctime attribute validation in TableSourceUtil#validateTableSource
e2daaaa is described below
commit e2daaaaba59e79cbef6bbf80309beb097310c2fb
Author: wenhuitang <we...@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