You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2017/05/29 14:16:28 UTC
flink git commit: [FLINK-6737] [table] Fix string reference variable
error
Repository: flink
Updated Branches:
refs/heads/master 64ca0fa22 -> 391d30584
[FLINK-6737] [table] Fix string reference variable error
This closes #4000.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/391d3058
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/391d3058
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/391d3058
Branch: refs/heads/master
Commit: 391d305848a8b19fa1df34aa0b247491c862ac7d
Parents: 64ca0fa
Author: sunjincheng121 <su...@gmail.com>
Authored: Sat May 27 14:03:06 2017 +0800
Committer: twalthr <tw...@apache.org>
Committed: Mon May 29 16:15:48 2017 +0200
----------------------------------------------------------------------
.../main/scala/org/apache/flink/table/api/TableEnvironment.scala | 2 +-
.../flink/table/functions/utils/UserDefinedFunctionUtils.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/391d3058/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
index 9f50f0c..4ceeece 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
@@ -461,7 +461,7 @@ abstract class TableEnvironment(val config: TableConfig) {
return new Table(this, CatalogNode(tablePath, table.getRowType(typeFactory)))
}
}
- throw new TableException(s"Table \'${tablePath.mkString(".")}\' was not found.")
+ throw new TableException(s"Table '${tablePath.mkString(".")}' was not found.")
}
private def getSchema(schemaPath: Array[String]): SchemaPlus = {
http://git-wip-us.apache.org/repos/asf/flink/blob/391d3058/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
index 1016574..2008711 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
@@ -178,7 +178,7 @@ object UserDefinedFunctionUtils {
s"add a @scala.annotation.varargs annotation.")
} else if (found.length > 1) {
throw new ValidationException(
- "Found multiple '${methodName}' methods which match the signature.")
+ s"Found multiple '${methodName}' methods which match the signature.")
}
found.headOption
}