-
Type:
Bug
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Component/s: Table SQL / API
-
Labels:
In TableSourceUtil#validateTableSource, when uses DefinedProctimeAttribute (proctime), it throws an incorrect exception message :
tableSource match { case p: DefinedProctimeAttribute if p.getProctimeAttribute != null => val proctimeAttribute = p.getProctimeAttribute val proctimeIdx = schema.getFieldNames.indexOf(proctimeAttribute) // ensure that field exists if (proctimeIdx < 0) { throw new ValidationException(s"Found a RowtimeAttributeDescriptor 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 " + s"'$proctimeAttribute' but field '$proctimeAttribute' is not of type TIMESTAMP.") } case _ => // nothing to validate }
It still contains the keyword "RowtimeAttributeDescriptor".
- links to