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

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


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new 1ee85e3  [hotfix][docs] Fix table example code
1ee85e3 is described below

commit 1ee85e3913ec4dc7751ae696fccb8cffb48f45a8
Author: Seth Wiesman <[email protected]>
AuthorDate: Tue Jul 14 11:57:40 2020 -0500

    [hotfix][docs] Fix table example code
---
 docs/dev/table/streaming/time_attributes.md    | 2 +-
 docs/dev/table/streaming/time_attributes.zh.md | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/dev/table/streaming/time_attributes.md 
b/docs/dev/table/streaming/time_attributes.md
index 0667d92..6896007 100644
--- a/docs/dev/table/streaming/time_attributes.md
+++ b/docs/dev/table/streaming/time_attributes.md
@@ -120,7 +120,7 @@ The processing time attribute is defined with the 
`.proctime` property during sc
 DataStream<Tuple2<String, String>> stream = ...;
 
 // declare an additional logical field as a processing time attribute
-Table table = tEnv.fromDataStream(stream, $("user_name"), $("data"), 
$("user_action_time").proctime()");
+Table table = tEnv.fromDataStream(stream, $("user_name"), $("data"), 
$("user_action_time").proctime());
 
 WindowedTable windowedTable = table.window(
         Tumble.over(lit(10).minutes())
diff --git a/docs/dev/table/streaming/time_attributes.zh.md 
b/docs/dev/table/streaming/time_attributes.zh.md
index 9cbc164..d44a1fa 100644
--- a/docs/dev/table/streaming/time_attributes.zh.md
+++ b/docs/dev/table/streaming/time_attributes.zh.md
@@ -120,7 +120,7 @@ GROUP BY TUMBLE(user_action_time, INTERVAL '10' MINUTE);
 DataStream<Tuple2<String, String>> stream = ...;
 
 // 声明一个额外的字段作为时间属性字段
-Table table = tEnv.fromDataStream(stream, $("user_name"), $("data"), 
$("user_action_time").proctime()");
+Table table = tEnv.fromDataStream(stream, $("user_name"), $("data"), 
$("user_action_time").proctime());
 
 WindowedTable windowedTable = table.window(
         Tumble.over(lit(10).minutes())

Reply via email to