You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/12/11 00:53:23 UTC
[incubator-streampark] 01/01: friendly code comments (#1259)
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch release-1.2.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit e47b0d0be9922021a65c29b71c10faa4c85ae29c
Author: lvlin241 <lv...@163.com>
AuthorDate: Thu Jul 21 10:54:46 2022 +0800
friendly code comments (#1259)
Co-authored-by: lvlin241 <lo...@chinatelecom.cn>
---
.../scala/com/streamxhub/streamx/flink/core/FlinkStreamTableTrait.scala | 2 +-
.../main/scala/com/streamxhub/streamx/flink/core/FlinkTableTrait.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkStreamTableTrait.scala b/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkStreamTableTrait.scala
index 16feb5b67..b8ecb6c9d 100644
--- a/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkStreamTableTrait.scala
+++ b/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkStreamTableTrait.scala
@@ -307,7 +307,7 @@ abstract class FlinkStreamTableTrait(val parameter: ParameterTool,
override def getConfig: TableConfig = tableEnv.getConfig
/**
- * deprecated!!! what are you fucking for??? don't call this method
+ * deprecated!!! Calling this method is not recommended!
*
* @param name
* @param dataStream
diff --git a/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkTableTrait.scala b/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkTableTrait.scala
index 8cdbb91b5..de1808a46 100644
--- a/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkTableTrait.scala
+++ b/streamx-flink/streamx-flink-shims/streamx-flink-shims-base/src/main/scala/com/streamxhub/streamx/flink/core/FlinkTableTrait.scala
@@ -139,7 +139,7 @@ abstract class FlinkTableTrait(val parameter: ParameterTool,
override def createStatementSet(): StatementSet = tableEnv.createStatementSet()
/**
- * deprecated!!! what are you fucking for??? don't call this method
+ * deprecated!!! Calling this method is not recommended!
*
* @param name
* @param dataStream