[hotfix] Fix confusing error message in TableSourceValidation

This closes apache#10263 .
tongcheng-elong · Nov 20, 2019 · 0bdcec9 · 0bdcec9
1 parent dde6b62
commit 0bdcec9
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...link-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java b/...link-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java
@@ -182,12 +182,11 @@ private static void validateLogicalTypeEqualsPhysical(
  ResolvedField resolvedField = resolveField(fieldName, tableSource);
  if (!resolvedField.getType().equals(logicalType)) {
  throw new ValidationException(String.format(
- "Type %s of table field '%s' does not " +
- "match with type '%s; of the field '%s' of the TableSource return type.",
+ "Type '%s' of table field '%s' does not match with type '%s' of field '%s' of the TableSource.",
  logicalType,
- resolvedField.getType(),
  fieldName,
- resolvedField.getType()));
+ resolvedField.getType(),
+ resolvedField.getName()));
  }
  }