This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new 3b202cf [hotfix][table-api] Properly deprecate
StreamTableEnvironment.execute
3b202cf is described below
commit 3b202cf35ec17ebb51df01cc6bc920a5e518f713
Author: Timo Walther <[email protected]>
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 ffb41ec..b398e2c 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
@@ -1149,7 +1149,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 c7b5935..36fa304 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
@@ -832,7 +832,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
