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 <hzyueme...@corp.netease.com> Authored: Fri Oct 14 13:38:59 2016 +0800 Committer: zentol <ches...@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(...)