You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/10/14 12:13:32 UTC
flink git commit: [FLINK-4827] [docs] Fix scala Streaming Table
example
Repository: flink
Updated Branches:
refs/heads/master 9948d4844 -> a648f88fb
[FLINK-4827] [docs] Fix scala Streaming Table example
This closes #2632.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a648f88f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a648f88f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a648f88f
Branch: refs/heads/master
Commit: a648f88fbc4780db99ecef8729d4cd7d29656dbd
Parents: 9948d48
Author: hzyuemeng1 <hz...@corp.netease.com>
Authored: Fri Oct 14 13:38:59 2016 +0800
Committer: zentol <ch...@apache.org>
Committed: Fri Oct 14 14:13:17 2016 +0200
----------------------------------------------------------------------
docs/dev/table_api.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a648f88f/docs/dev/table_api.md
----------------------------------------------------------------------
diff --git a/docs/dev/table_api.md b/docs/dev/table_api.md
index 91ccd8a..d464cb9 100644
--- a/docs/dev/table_api.md
+++ b/docs/dev/table_api.md
@@ -1082,7 +1082,7 @@ Table result = tableEnv.sql(
<div data-lang="scala" markdown="1">
{% highlight scala %}
val env = StreamExecutionEnvironment.getExecutionEnvironment
-val tEnv = TableEnvironment.getTableEnvironment(env)
+val tableEnv = TableEnvironment.getTableEnvironment(env)
// read a DataStream from an external source
val ds: DataStream[(Long, String, Integer)] = env.addSource(...)