Repository: flink Updated Branches: refs/heads/release-1.3 5d3bb6475 -> 2ea9c5f56
[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/2ea9c5f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ea9c5f5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2ea9c5f5 Branch: refs/heads/release-1.3 Commit: 2ea9c5f563821aa2f394127dbd34a7c3b1a2ccf1 Parents: 5d3bb64 Author: sunjincheng121 <sunjincheng...@gmail.com> Authored: Sat May 27 14:03:06 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 29 16:17:42 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/2ea9c5f5/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/2ea9c5f5/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 }
