You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/03/04 13:47:21 UTC

[flink] branch release-1.10 updated: [hotfix][scaladoc] Add missing parameter in DataStreamConversions's scaladoc

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new 438f096  [hotfix][scaladoc] Add missing parameter in DataStreamConversions's scaladoc
438f096 is described below

commit 438f096d943ea467a6eee6439d5225358302174b
Author: Paul Lam <pa...@gmail.com>
AuthorDate: Sun Mar 1 18:42:28 2020 +0800

    [hotfix][scaladoc] Add missing parameter in DataStreamConversions's scaladoc
    
    This closes #11272.
---
 .../scala/org/apache/flink/table/planner/DataStreamConversions.scala   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions.scala b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions.scala
index e4cd58b..96fa045 100644
--- a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions.scala
+++ b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions.scala
@@ -43,7 +43,8 @@ object DataStreamConversions {
     *                            field naming might be lost during optimization.
     * @param withChangeFlag      Set to true to emit records with change flags.
     * @param requestedOutputType The [[TypeInformation]] of the resulting [[DataStream]].
-    * @tparam A The type of the resulting [[DataStream]].
+    * @param config              The [[TableConfig]] of the current [[TableEnvironment]].
+    * @tparam A                  The type of the resulting [[DataStream]].
     * @return The [[DataStream]] of requested type.
     */
   def convert[A](