You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2018/12/14 15:39:40 UTC
[flink] branch master updated: [hotfix] [docs] Correct the field
name in Connect to External Systems doc
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new ff848d0 [hotfix] [docs] Correct the field name in Connect to External Systems doc
ff848d0 is described below
commit ff848d0dcded2bf46725d49d01d9be672f0f3d5b
Author: Yangze Guo <ka...@gmail.com>
AuthorDate: Fri Dec 14 19:59:20 2018 +0800
[hotfix] [docs] Correct the field name in Connect to External Systems doc
This closes #7311.
---
docs/dev/table/connect.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/dev/table/connect.md b/docs/dev/table/connect.md
index 1cc97a3..9b466ae 100644
--- a/docs/dev/table/connect.md
+++ b/docs/dev/table/connect.md
@@ -154,7 +154,7 @@ tableEnvironment
new Schema()
.field("rowtime", Types.SQL_TIMESTAMP)
.rowtime(new Rowtime()
- .timestampsFromField("ts")
+ .timestampsFromField("timestamp")
.watermarksPeriodicBounded(60000)
)
.field("user", Types.LONG)
@@ -1166,7 +1166,7 @@ ClusterBuilder builder = ... // configure Cassandra cluster connection
CassandraAppendTableSink sink = new CassandraAppendTableSink(
builder,
// the query must match the schema of the table
- INSERT INTO flink.myTable (id, name, value) VALUES (?, ?, ?));
+ "INSERT INTO flink.myTable (id, name, value) VALUES (?, ?, ?)");
tableEnv.registerTableSink(
"cassandraOutputTable",
@@ -1187,7 +1187,7 @@ val builder: ClusterBuilder = ... // configure Cassandra cluster connection
val sink: CassandraAppendTableSink = new CassandraAppendTableSink(
builder,
// the query must match the schema of the table
- INSERT INTO flink.myTable (id, name, value) VALUES (?, ?, ?))
+ "INSERT INTO flink.myTable (id, name, value) VALUES (?, ?, ?)")
tableEnv.registerTableSink(
"cassandraOutputTable",