This is an automated email from the ASF dual-hosted git repository.
panyuepeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 676eb13e3 [Improve][All] Improvement of deprecated annotation (#3267)
676eb13e3 is described below
commit 676eb13e35d7b3820cdac09b1a0bf2e1a6a72b0b
Author: ChunFuWu <[email protected]>
AuthorDate: Sun Oct 22 23:08:58 2023 +0800
[Improve][All] Improvement of deprecated annotation (#3267)
---
.../streampark/common/conf/K8sFlinkConfig.scala | 12 ++++-----
.../impl/KubernetesNativeApplicationClient.scala | 8 ++++--
.../impl/KubernetesNativeSessionClient.scala | 8 ++++--
.../flink/core/scala/FlinkStreaming.scala | 4 +--
.../flink/core/FlinkStreamTableTrait.scala | 30 +++++++++++-----------
.../streampark/flink/core/FlinkTableTrait.scala | 8 +++---
.../streampark/flink/core/SqlCommandParser.scala | 4 +--
.../flink/core/conf/FlinkRunOption.scala | 4 +--
.../streampark/flink/core/StreamTableContext.scala | 16 ++++++------
.../streampark/flink/core/TableContext.scala | 16 ++++++------
.../streampark/flink/core/StreamTableContext.scala | 16 ++++++------
.../streampark/flink/core/TableContext.scala | 16 ++++++------
.../streampark/flink/core/StreamTableContext.scala | 14 +++++-----
.../streampark/flink/core/TableContext.scala | 16 ++++++------
14 files changed, 90 insertions(+), 82 deletions(-)
diff --git
a/streampark-common/src/main/scala/org/apache/streampark/common/conf/K8sFlinkConfig.scala
b/streampark-common/src/main/scala/org/apache/streampark/common/conf/K8sFlinkConfig.scala
index 95ed2de1c..3b70594a9 100644
---
a/streampark-common/src/main/scala/org/apache/streampark/common/conf/K8sFlinkConfig.scala
+++
b/streampark-common/src/main/scala/org/apache/streampark/common/conf/K8sFlinkConfig.scala
@@ -32,7 +32,7 @@ object K8sFlinkConfig {
// ======= deprecated =======
- @deprecated
+ @Deprecated
val jobStatusTrackTaskTimeoutSec: InternalOption = InternalOption(
key = "streampark.flink-k8s.tracking.polling-task-timeout-sec.job-status",
defaultValue = 120L,
@@ -40,7 +40,7 @@ object K8sFlinkConfig {
description = "run timeout seconds of single flink-k8s metrics tracking
task"
)
- @deprecated
+ @Deprecated
val metricTrackTaskTimeoutSec: InternalOption = InternalOption(
key =
"streampark.flink-k8s.tracking.polling-task-timeout-sec.cluster-metric",
defaultValue = 120L,
@@ -48,7 +48,7 @@ object K8sFlinkConfig {
description = "run timeout seconds of single flink-k8s job status tracking
task"
)
- @deprecated
+ @Deprecated
val jobStatueTrackTaskIntervalSec: InternalOption = InternalOption(
key = "streampark.flink-k8s.tracking.polling-interval-sec.job-status",
defaultValue = 5L,
@@ -56,7 +56,7 @@ object K8sFlinkConfig {
description = "interval seconds between two single flink-k8s metrics
tracking task"
)
- @deprecated
+ @Deprecated
val metricTrackTaskIntervalSec: InternalOption = InternalOption(
key = "streampark.flink-k8s.tracking.polling-interval-sec.cluster-metric",
defaultValue = 5L,
@@ -64,7 +64,7 @@ object K8sFlinkConfig {
description = "interval seconds between two single flink-k8s metrics
tracking task"
)
- @deprecated
+ @Deprecated
val silentStateJobKeepTrackingSec: InternalOption = InternalOption(
key = "streampark.flink-k8s.tracking.silent-state-keep-sec",
defaultValue = 60,
@@ -85,7 +85,7 @@ object K8sFlinkConfig {
)
/** kubernetes default namespace */
- @deprecated
+ @Deprecated
val DEFAULT_KUBERNETES_NAMESPACE = "default"
}
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala
index f53a3c74d..dd029f552 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala
@@ -31,8 +31,12 @@ import org.apache.flink.configuration.{Configuration,
DeploymentOptions, Pipelin
import org.apache.flink.kubernetes.KubernetesClusterDescriptor
import org.apache.flink.kubernetes.configuration.KubernetesConfigOptions
-/** kubernetes native application mode submit */
-@deprecated("use KubernetesApplicationClientV2 instead")
+/**
+ * Kubernetes native application mode submit.
+ * @deprecated
+ * Please use [[KubernetesApplicationClientV2]] instead.
+ */
+@Deprecated
object KubernetesNativeApplicationClient extends KubernetesNativeClientTrait {
@throws[Exception]
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
index f98ce4c43..8004fb91c 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
@@ -40,8 +40,12 @@ import scala.collection.convert.ImplicitConversions._
import scala.language.postfixOps
import scala.util.{Failure, Success, Try}
-/** kubernetes native session mode submit */
-@deprecated("use KubernetesSessionClientV2 instead")
+/**
+ * Kubernetes native session mode submit.
+ * @deprecated
+ * Please use [[KubernetesSessionClientV2]] instead.
+ */
+@Deprecated
object KubernetesNativeSessionClient extends KubernetesNativeClientTrait with
Logger {
@throws[Exception]
diff --git
a/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/FlinkStreaming.scala
b/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/FlinkStreaming.scala
index e0cee8ecb..7dffccd29 100644
---
a/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/FlinkStreaming.scala
+++
b/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/FlinkStreaming.scala
@@ -44,12 +44,12 @@ class StreamingContext(
/** Recommend use this Api to start task */
def start(): JobExecutionResult = execute()
- @deprecated override def execute(): JobExecutionResult = {
+ @Deprecated override def execute(): JobExecutionResult = {
val appName = parameter.getAppName(required = true)
execute(appName)
}
- @deprecated override def execute(jobName: String): JobExecutionResult = {
+ @Deprecated override def execute(jobName: String): JobExecutionResult = {
printLogo(s"FlinkStreaming $jobName Starting...")
super.execute(jobName)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala
index a50116925..53e381275 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala
@@ -76,7 +76,7 @@ abstract class FlinkStreamTableTrait(
execute(appName)
}
- @deprecated def execute(jobName: String): JobExecutionResult = {
+ @Deprecated def execute(jobName: String): JobExecutionResult = {
printLogo(s"FlinkStreamTable $jobName Starting...")
if (isConvertedToDataStream) {
streamEnv.execute(jobName)
@@ -246,25 +246,25 @@ abstract class FlinkStreamTableTrait(
def $isForceUnalignedCheckpoints: Boolean =
this.streamEnv.isForceUnalignedCheckpoints
- @deprecated def $enableCheckpointing(
+ @Deprecated def $enableCheckpointing(
interval: Long,
mode: CheckpointingMode,
force: Boolean): StreamExecutionEnvironment =
this.streamEnv.enableCheckpointing(interval, mode, force)
- @deprecated def $enableCheckpointing(): StreamExecutionEnvironment =
+ @Deprecated def $enableCheckpointing(): StreamExecutionEnvironment =
this.streamEnv.enableCheckpointing()
- @deprecated def $generateSequence(from: Long, to: Long): DataStream[Long] =
+ @Deprecated def $generateSequence(from: Long, to: Long): DataStream[Long] =
this.streamEnv.generateSequence(from, to)
- @deprecated def $readFileStream(
+ @Deprecated def $readFileStream(
StreamPath: String,
intervalMillis: Long,
watchType: FileMonitoringFunction.WatchType): DataStream[String] =
this.streamEnv.readFileStream(StreamPath, intervalMillis, watchType)
- @deprecated def $readFile[T](
+ @Deprecated def $readFile[T](
inputFormat: FileInputFormat[T],
filePath: String,
watchType: FileProcessingMode,
@@ -403,38 +403,38 @@ abstract class FlinkStreamTableTrait(
* @param dataStream
* @tparam T
*/
- @deprecated override def registerFunction[T](name: String, tf:
TableFunction[T])(implicit
+ @Deprecated override def registerFunction[T](name: String, tf:
TableFunction[T])(implicit
info: TypeInformation[T]): Unit =
tableEnv.registerFunction(name, tf)
- @deprecated override def registerFunction[T, ACC](name: String, f:
AggregateFunction[T, ACC])(
+ @Deprecated override def registerFunction[T, ACC](name: String, f:
AggregateFunction[T, ACC])(
implicit
info1: TypeInformation[T],
info2: TypeInformation[ACC]): Unit = tableEnv.registerFunction(name, f)
- @deprecated override def registerFunction[T, ACC](
+ @Deprecated override def registerFunction[T, ACC](
name: String,
f: TableAggregateFunction[T, ACC])(implicit
info1: TypeInformation[T],
info2: TypeInformation[ACC]): Unit = tableEnv.registerFunction(name, f)
- @deprecated override def registerDataStream[T](name: String, dataStream:
DataStream[T]): Unit =
+ @Deprecated override def registerDataStream[T](name: String, dataStream:
DataStream[T]): Unit =
tableEnv.registerDataStream(name, dataStream)
- @deprecated override def registerDataStream[T](
+ @Deprecated override def registerDataStream[T](
name: String,
dataStream: DataStream[T],
fields: Expression*): Unit =
tableEnv.registerDataStream(name, dataStream, fields: _*)
- @deprecated override def registerFunction(name: String, function:
ScalarFunction): Unit =
+ @Deprecated override def registerFunction(name: String, function:
ScalarFunction): Unit =
tableEnv.registerFunction(name, function)
- @deprecated override def registerTable(name: String, table: Table): Unit =
+ @Deprecated override def registerTable(name: String, table: Table): Unit =
tableEnv.registerTable(name, table)
- @deprecated override def scan(tablePath: String*): Table =
tableEnv.scan(tablePath: _*)
+ @Deprecated override def scan(tablePath: String*): Table =
tableEnv.scan(tablePath: _*)
- @deprecated override def getCompletionHints(statement: String, position:
Int): Array[String] =
+ @Deprecated override def getCompletionHints(statement: String, position:
Int): Array[String] =
tableEnv.getCompletionHints(statement, position)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableTrait.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableTrait.scala
index 1d0873341..e581f857c 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableTrait.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableTrait.scala
@@ -149,14 +149,14 @@ abstract class FlinkTableTrait(val parameter:
ParameterTool, private val tableEn
override def createStatementSet(): StatementSet =
tableEnv.createStatementSet()
- @deprecated override def registerFunction(name: String, function:
ScalarFunction): Unit =
+ @Deprecated override def registerFunction(name: String, function:
ScalarFunction): Unit =
tableEnv.registerFunction(name, function)
- @deprecated override def registerTable(name: String, table: Table): Unit =
+ @Deprecated override def registerTable(name: String, table: Table): Unit =
tableEnv.registerTable(name, table)
- @deprecated override def scan(tablePath: String*): Table =
tableEnv.scan(tablePath: _*)
+ @Deprecated override def scan(tablePath: String*): Table =
tableEnv.scan(tablePath: _*)
- @deprecated override def getCompletionHints(statement: String, position:
Int): Array[String] =
+ @Deprecated override def getCompletionHints(statement: String, position:
Int): Array[String] =
tableEnv.getCompletionHints(statement, position)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala
index 0d21aab5c..dc4de596c 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala
@@ -384,12 +384,12 @@ object SqlCommand extends enumeratum.Enum[SqlCommand] {
* </pre>
*/
/** This is SQL Client's syntax, don't use in our platform. */
- @deprecated
+ @Deprecated
case object BEGIN_STATEMENT_SET
extends SqlCommand("begin statement set", "BEGIN\\s+STATEMENT\\s+SET",
Converters.NO_OPERANDS)
/** This is SQL Client's syntax, don't use in our platform. */
- @deprecated
+ @Deprecated
case object END_STATEMENT_SET
extends SqlCommand("end statement set", "END", Converters.NO_OPERANDS)
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/conf/FlinkRunOption.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/conf/FlinkRunOption.scala
index dabc6d027..8a238ff20 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/conf/FlinkRunOption.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/conf/FlinkRunOption.scala
@@ -62,7 +62,7 @@ object FlinkRunOption {
* @deprecated
* use non-prefixed variant {@link #DETACHED_OPTION} for both YARN and
non-YARN deployments
*/
- @deprecated val YARN_DETACHED_OPTION =
+ @Deprecated val YARN_DETACHED_OPTION =
new Option(
"yd",
"yarndetached",
@@ -175,7 +175,7 @@ object FlinkRunOption {
.desc("Allows specifying multiple generic configuration options. The
available options can be found at
https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html";)
.build
- @deprecated val EXECUTOR_OPTION = new Option(
+ @Deprecated val EXECUTOR_OPTION = new Option(
"e",
"executor",
true,
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
index af95943ea..967674c9f 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
@@ -47,7 +47,7 @@ class StreamTableContext(
/** for Java */
def this(args: StreamTableEnvConfig) =
this(FlinkTableInitializer.initialize(args))
- @deprecated override def connect(
+ @Deprecated override def connect(
connectorDescriptor: ConnectorDescriptor): StreamTableDescriptor =
tableEnv.connect(connectorDescriptor)
@@ -58,24 +58,24 @@ class StreamTableContext(
override def createStatementSet(): StatementSet =
tableEnv.createStatementSet()
- @deprecated override def fromTableSource(source: TableSource[_]): Table =
+ @Deprecated override def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated override def insertInto(
+ @Deprecated override def insertInto(
table: Table,
sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated override def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated override def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated override def explain(table: Table): String =
tableEnv.explain(table)
+ @Deprecated override def explain(table: Table): String =
tableEnv.explain(table)
- @deprecated override def explain(table: Table, extended: Boolean): String =
+ @Deprecated override def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
+ @Deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
index ae4edadad..bbe35967c 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
@@ -41,7 +41,7 @@ class TableContext(override val parameter: ParameterTool,
private val tableEnv:
*/
def this(args: TableEnvConfig) = this(FlinkTableInitializer.initialize(args))
- @deprecated override def connect(
+ @Deprecated override def connect(
connectorDescriptor: ConnectorDescriptor): ConnectTableDescriptor =
tableEnv.connect(connectorDescriptor)
@@ -50,24 +50,24 @@ class TableContext(override val parameter: ParameterTool,
private val tableEnv:
null
}
- @deprecated override def fromTableSource(source: TableSource[_]): Table =
+ @Deprecated override def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated override def insertInto(
+ @Deprecated override def insertInto(
table: Table,
sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated override def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated override def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated override def explain(table: Table): String =
tableEnv.explain(table)
+ @Deprecated override def explain(table: Table): String =
tableEnv.explain(table)
- @deprecated override def explain(table: Table, extended: Boolean): String =
+ @Deprecated override def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
+ @Deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
index ea7b22cda..94aee6ee9 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
@@ -108,7 +108,7 @@ class StreamTableContext(
override def listFullModules(): Array[ModuleEntry] =
tableEnv.listFullModules()
- @deprecated override def connect(
+ @Deprecated override def connect(
connectorDescriptor: ConnectorDescriptor): StreamTableDescriptor =
tableEnv.connect(connectorDescriptor)
@@ -119,20 +119,20 @@ class StreamTableContext(
override def createStatementSet(): StatementSet =
tableEnv.createStatementSet()
- @deprecated def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
+ @Deprecated def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated def insertInto(table: Table, sinkPath: String,
sinkPathContinued: String*): Unit =
+ @Deprecated def insertInto(table: Table, sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated def explain(table: Table): String = tableEnv.explain(table)
+ @Deprecated def explain(table: Table): String = tableEnv.explain(table)
- @deprecated def explain(table: Table, extended: Boolean): String =
+ @Deprecated def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated def sqlUpdate(stmt: String): Unit = tableEnv.sqlUpdate(stmt)
+ @Deprecated def sqlUpdate(stmt: String): Unit = tableEnv.sqlUpdate(stmt)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
index f23e4c9c5..96ac48549 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
@@ -46,7 +46,7 @@ class TableContext(override val parameter: ParameterTool,
private val tableEnv:
override def listFullModules(): Array[ModuleEntry] =
tableEnv.listFullModules()
- @deprecated override def connect(
+ @Deprecated override def connect(
connectorDescriptor: ConnectorDescriptor): ConnectTableDescriptor =
tableEnv.connect(connectorDescriptor)
@@ -55,24 +55,24 @@ class TableContext(override val parameter: ParameterTool,
private val tableEnv:
null
}
- @deprecated override def fromTableSource(source: TableSource[_]): Table =
+ @Deprecated override def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated override def insertInto(
+ @Deprecated override def insertInto(
table: Table,
sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated override def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated override def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated override def explain(table: Table): String =
tableEnv.explain(table)
+ @Deprecated override def explain(table: Table): String =
tableEnv.explain(table)
- @deprecated override def explain(table: Table, extended: Boolean): String =
+ @Deprecated override def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
+ @Deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
index bd7e456c9..44a14dfa9 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala
@@ -129,21 +129,21 @@ class StreamTableContext(
override def createStatementSet(): StreamStatementSet =
tableEnv.createStatementSet()
- @deprecated def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
+ @Deprecated def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated def insertInto(table: Table, sinkPath: String,
sinkPathContinued: String*): Unit =
+ @Deprecated def insertInto(table: Table, sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated def explain(table: Table): String = tableEnv.explain(table)
+ @Deprecated def explain(table: Table): String = tableEnv.explain(table)
- @deprecated def explain(table: Table, extended: Boolean): String =
+ @Deprecated def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated def sqlUpdate(stmt: String): Unit = tableEnv.sqlUpdate(stmt)
+ @Deprecated def sqlUpdate(stmt: String): Unit = tableEnv.sqlUpdate(stmt)
}
diff --git
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
index abbe13822..fcd7708f3 100644
---
a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
+++
b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/TableContext.scala
@@ -63,29 +63,29 @@ class TableContext(override val parameter: ParameterTool,
private val tableEnv:
def from(descriptor: TableDescriptor): Table = tableEnv.from(descriptor)
- @deprecated override def execute(jobName: String): JobExecutionResult = {
+ @Deprecated override def execute(jobName: String): JobExecutionResult = {
printLogo(s"FlinkTable $jobName Starting...")
null
}
- @deprecated override def fromTableSource(source: TableSource[_]): Table =
+ @Deprecated override def fromTableSource(source: TableSource[_]): Table =
tableEnv.fromTableSource(source)
- @deprecated override def insertInto(
+ @Deprecated override def insertInto(
table: Table,
sinkPath: String,
sinkPathContinued: String*): Unit =
tableEnv.insertInto(table, sinkPath, sinkPathContinued: _*)
- @deprecated override def insertInto(targetPath: String, table: Table): Unit =
+ @Deprecated override def insertInto(targetPath: String, table: Table): Unit =
tableEnv.insertInto(targetPath, table)
- @deprecated override def explain(table: Table): String =
tableEnv.explain(table)
+ @Deprecated override def explain(table: Table): String =
tableEnv.explain(table)
- @deprecated override def explain(table: Table, extended: Boolean): String =
+ @Deprecated override def explain(table: Table, extended: Boolean): String =
tableEnv.explain(table, extended)
- @deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
+ @Deprecated override def explain(extended: Boolean): String =
tableEnv.explain(extended)
- @deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
+ @Deprecated override def sqlUpdate(stmt: String): Unit =
tableEnv.sqlUpdate(stmt)
}
