You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2019/05/10 06:07:30 UTC
[flink] branch master updated: [hotfix][table] Fix typo for method
name in FieldReferenceLookup.
This is an automated email from the ASF dual-hosted git repository.
jincheng 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 2ffa618 [hotfix][table] Fix typo for method name in FieldReferenceLookup.
2ffa618 is described below
commit 2ffa618b989ffbb35b7f137a258623aebbc27f25
Author: sunjincheng121 <su...@gmail.com>
AuthorDate: Fri May 10 09:49:36 2019 +0800
[hotfix][table] Fix typo for method name in FieldReferenceLookup.
This closes #8393
---
.../flink/table/expressions/lookups/FieldReferenceLookup.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/lookups/FieldReferenceLookup.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/lookups/FieldReferenceLookup.java
index 5cd6410..5e219d7 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/lookups/FieldReferenceLookup.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/lookups/FieldReferenceLookup.java
@@ -65,7 +65,7 @@ public class FieldReferenceLookup {
} else if (matchingFields.size() == 0) {
return Optional.empty();
} else {
- throw failAmbigousColumn(name);
+ throw failAmbiuguousColumn(name);
}
}
@@ -97,14 +97,14 @@ public class FieldReferenceLookup {
FieldReferenceExpression::getName,
Function.identity(),
(fieldRef1, fieldRef2) -> {
- throw failAmbigousColumn(fieldRef1.getName());
+ throw failAmbiuguousColumn(fieldRef1.getName());
},
// we need to maintain order of fields within input for resolving e.g. '*' reference
LinkedHashMap::new
));
}
- private static ValidationException failAmbigousColumn(String name) {
- return new ValidationException("Ambigous column name: " + name);
+ private static ValidationException failAmbiuguousColumn(String name) {
+ return new ValidationException("Ambiguous column name: " + name);
}
}