From 7b07fa5a09279a55c99d80db92ebf98a7dcd9644 Mon Sep 17 00:00:00 2001 From: Fabian Hueske Date: Fri, 23 Mar 2018 22:14:46 +0100 Subject: [PATCH] [hotfix] [table] Add Java deprecation annotation to TableEnvironment.sql(). --- .../scala/org/apache/flink/table/api/TableEnvironment.scala | 2 ++ 1 file changed, 2 insertions(+) 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 13e56567ac038..d6106bec69bd9 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 @@ -574,9 +574,11 @@ abstract class TableEnvironment(val config: TableConfig) { * tEnv.sql(s"SELECT * FROM $table") * }}} * + * @deprecated Use sqlQuery() instead. * @param query The SQL query to evaluate. * @return The result of the query as Table. */ + @Deprecated @deprecated("Please use sqlQuery() instead.") def sql(query: String): Table = { sqlQuery(query)