GitHub user hzyuemeng1 opened a pull request:

    [FLINK-4827][Docs] The scala example of SQL on Streaming Tables with wrong 
variable name…

    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val tEnv = TableEnvironment.getTableEnvironment(env)
    // read a DataStream from an external source
    val ds: DataStream[(Long, String, Integer)] = env.addSource(...)
    // register the DataStream under the name "Orders"
    tableEnv.registerDataStream("Orders", ds, 'user, 'product, 'amount)
    // run a SQL query on the Table and retrieve the result as a new Table
    val result = tableEnv.sql(
    "SELECT product, amount FROM Orders WHERE product LIKE '%Rubber%'")
    There is no variable named tableEnv had defined ,Only tEnv defined here

You can merge this pull request into a Git repository by running:

    $ git pull 

Alternatively you can review and apply these changes as the patch at:

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2632
commit a015a22248295041eef708e84a9d64ec4dcbbecb
Author: hzyuemeng1 <>
Date:   2016-10-14T05:38:59Z

    The scala example of SQL on Streaming Tables with wrong variable name in 
flink document


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

Reply via email to