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:40:19 UTC
[flink] branch release-1.7 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 release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.7 by this push:
new 4263013 [hotfix] [docs] Correct the field name in Connect to External Systems doc
4263013 is described below
commit 426301328e59ce67e2ab59702ab24f2076083a39
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 d867771..e7f9263 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",