This is an automated email from the ASF dual-hosted git repository. dannycranmer 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 919f2a0ee2e [hotfix][docs][Connector/Firehose] Add missing references to Firehose connector 919f2a0ee2e is described below commit 919f2a0ee2e58052cbd7c690d7f05fc2f124153f Author: Danny Cranmer <dannycran...@apache.org> AuthorDate: Mon Dec 5 00:02:57 2022 +0000 [hotfix][docs][Connector/Firehose] Add missing references to Firehose connector --- docs/content.zh/docs/connectors/datastream/guarantees.md | 9 +++++++-- docs/content.zh/docs/connectors/table/formats/overview.md | 4 ++++ docs/content.zh/docs/connectors/table/overview.md | 6 ++++++ docs/content/docs/connectors/datastream/guarantees.md | 7 ++++++- docs/content/docs/connectors/table/formats/overview.md | 4 ++++ docs/content/docs/connectors/table/overview.md | 6 ++++++ docs/data/sql_connectors.yml | 4 ++-- 7 files changed, 35 insertions(+), 5 deletions(-) diff --git a/docs/content.zh/docs/connectors/datastream/guarantees.md b/docs/content.zh/docs/connectors/datastream/guarantees.md index 828109c5aeb..12da9b07788 100644 --- a/docs/content.zh/docs/connectors/datastream/guarantees.md +++ b/docs/content.zh/docs/connectors/datastream/guarantees.md @@ -47,7 +47,7 @@ under the License. <td>根据你的版本用恰当的 Kafka 连接器</td> </tr> <tr> - <td>AWS Kinesis Streams</td> + <td>Amazon Kinesis Data Streams</td> <td>精确一次</td> <td></td> </tr> @@ -106,7 +106,12 @@ under the License. <td>只有当更新是幂等时,保证精确一次</td> </tr> <tr> - <td>AWS Kinesis Streams</td> + <td>Amazon Kinesis Data Streams</td> + <td>至少一次</td> + <td></td> + </tr> + <tr> + <td>Amazon Kinesis Data Firehose</td> <td>至少一次</td> <td></td> </tr> diff --git a/docs/content.zh/docs/connectors/table/formats/overview.md b/docs/content.zh/docs/connectors/table/formats/overview.md index 644bbc6b86c..2e30d7dda72 100644 --- a/docs/content.zh/docs/connectors/table/formats/overview.md +++ b/docs/content.zh/docs/connectors/table/formats/overview.md @@ -43,6 +43,7 @@ Flink 支持以下格式: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> <tr> @@ -50,6 +51,7 @@ Flink 支持以下格式: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a>, <a href="{{< ref "docs/connectors/table/elasticsearch" >}}">Elasticsearch</a></td> </tr> @@ -58,6 +60,7 @@ Flink 支持以下格式: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> <tr> @@ -98,6 +101,7 @@ Flink 支持以下格式: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> </tbody> diff --git a/docs/content.zh/docs/connectors/table/overview.md b/docs/content.zh/docs/connectors/table/overview.md index adecb887767..2250ace9a15 100644 --- a/docs/content.zh/docs/connectors/table/overview.md +++ b/docs/content.zh/docs/connectors/table/overview.md @@ -72,6 +72,12 @@ Flink natively support various connectors. The following tables list all availab <td>Unbounded Scan</td> <td>Streaming Sink</td> </tr> + <tr> + <td><a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a></td> + <td></td> + <td>Not supported</td> + <td>Streaming Sink</td> + </tr> <tr> <td><a href="{{< ref "docs/connectors/table/jdbc" >}}">JDBC</a></td> <td></td> diff --git a/docs/content/docs/connectors/datastream/guarantees.md b/docs/content/docs/connectors/datastream/guarantees.md index 93c4a802e64..b7915ba3066 100644 --- a/docs/content/docs/connectors/datastream/guarantees.md +++ b/docs/content/docs/connectors/datastream/guarantees.md @@ -111,7 +111,12 @@ state updates) of Flink coupled with bundled sinks: <td>exactly once only for idempotent updates</td> </tr> <tr> - <td>AWS Kinesis Streams</td> + <td>Amazon Kinesis Data Streams</td> + <td>at least once</td> + <td></td> + </tr> + <tr> + <td>Amazon Kinesis Data Firehose</td> <td>at least once</td> <td></td> </tr> diff --git a/docs/content/docs/connectors/table/formats/overview.md b/docs/content/docs/connectors/table/formats/overview.md index a07e2ee042d..987ba8d8820 100644 --- a/docs/content/docs/connectors/table/formats/overview.md +++ b/docs/content/docs/connectors/table/formats/overview.md @@ -43,6 +43,7 @@ Flink supports the following formats: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> <tr> @@ -50,6 +51,7 @@ Flink supports the following formats: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a>, <a href="{{< ref "docs/connectors/table/elasticsearch" >}}">Elasticsearch</a></td> </tr> @@ -58,6 +60,7 @@ Flink supports the following formats: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> <tr> @@ -98,6 +101,7 @@ Flink supports the following formats: <td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>, <a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>, <a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>, + <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>, <a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td> </tr> </tbody> diff --git a/docs/content/docs/connectors/table/overview.md b/docs/content/docs/connectors/table/overview.md index 60a0552cf80..80058e32f2b 100644 --- a/docs/content/docs/connectors/table/overview.md +++ b/docs/content/docs/connectors/table/overview.md @@ -72,6 +72,12 @@ Flink natively support various connectors. The following tables list all availab <td>Unbounded Scan</td> <td>Streaming Sink</td> </tr> + <tr> + <td><a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a></td> + <td></td> + <td>Not supported</td> + <td>Streaming Sink</td> + </tr> <tr> <td><a href="{{< ref "docs/connectors/table/jdbc" >}}">JDBC</a></td> <td></td> diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml index e8077cad0c4..79dc83e22eb 100644 --- a/docs/data/sql_connectors.yml +++ b/docs/data/sql_connectors.yml @@ -167,13 +167,13 @@ upsert-kafka: sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/$version/flink-sql-connector-kafka-$version.jar kinesis: - name: Kinesis + name: Amazon Kinesis Data Streams category: connector maven: flink-connector-kinesis sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kinesis/$version/flink-sql-connector-kinesis-$version.jar aws-kinesis-firehose: - name: AWS Kinesis Firehose + name: Amazon Kinesis Data Firehose category: connector maven: flink-connector-kinesis-firehose sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-aws-kinesis-firehose/$version/flink-sql-connector-aws-kinesis-firehose-$version.jar