This is an automated email from the ASF dual-hosted git repository.
twalthr 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 fa0be65 [hotfix][table-api] Properly deprecate
StreamTableEnvironment.execute
fa0be65 is described below
commit fa0be65cf81cf4cb53ddbfb8c5cedb271e264f19
Author: Timo Walther <twal...@apache.org>
AuthorDate: Thu Apr 22 11:28:34 2021 +0200
[hotfix][table-api] Properly deprecate StreamTableEnvironment.execute
---
.../org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java | 3 +++
.../apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala | 3 +++
2 files changed, 6 insertions(+)
diff --git
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java
index 7158bfe..64eb67b 100644
---
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java
+++
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java
@@ -1142,7 +1142,10 @@ public interface StreamTableEnvironment extends
TableEnvironment {
* @param jobName Desired name of the job
* @return The result of the job execution, containing elapsed time and
accumulators.
* @throws Exception which occurs during job execution.
+ * @deprecated Use {@link StreamExecutionEnvironment#execute(String)}
instead or directly call
+ * the execute methods of the Table API such as {@link
#executeSql(String)}.
*/
+ @Deprecated
@Override
JobExecutionResult execute(String jobName) throws Exception;
}
diff --git
a/flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala
b/flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala
index ff726d3..fc53cc7 100644
---
a/flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala
+++
b/flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala
@@ -826,7 +826,10 @@ trait StreamTableEnvironment extends TableEnvironment {
* @param jobName Desired name of the job
* @return The result of the job execution, containing elapsed time and
accumulators.
* @throws Exception which occurs during job execution.
+ * @deprecated Use [[StreamExecutionEnvironment.execute(String)]] instead
or directly call
+ * the execute methods of the Table API such as
[[executeSql(String)]].
*/
+ @deprecated
@throws[Exception]
override def execute(jobName: String): JobExecutionResult
