flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hzyuemeng1 <...@git.apache.org>
Subject [GitHub] flink pull request #2632: [FLINK-4827][Docs] The scala example of SQL on Str...
Date Fri, 14 Oct 2016 05:53:35 GMT
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 https://github.com/hzyuemeng1/flink document_dev_tableapi_variable_name

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 <hzyuemeng1@corp.netease.com>
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message