[hotfix][table-api] Properly deprecate StreamTableEnvironment.execute

apache · Apr 22, 2021 · fa0be65 · fa0be65
1 parent 4b5e8cc
commit fa0be65
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...a-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java b/...a-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java
@@ -1142,7 +1142,10 @@ DataStream<Row> toChangelogStream(
      * @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/...ridge/src/main/scala/org/apache/flink/table/api/bridge/scala/StreamTableEnvironment.scala b/...ridge/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