You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by ke...@apache.org on 2023/08/23 00:50:42 UTC
[incubator-paimon] branch master updated: Modify the flink documentation link to point to the flink stable version. (#1866)
This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 5c31cadfe Modify the flink documentation link to point to the flink stable version. (#1866)
5c31cadfe is described below
commit 5c31cadfe0fa9117563a14acd5c3d8d850d51071
Author: Kerwin <37...@users.noreply.github.com>
AuthorDate: Wed Aug 23 08:50:37 2023 +0800
Modify the flink documentation link to point to the flink stable version. (#1866)
---
docs/content/api/flink-api.md | 2 +-
docs/content/concepts/append-only-table.md | 2 +-
docs/content/engines/flink.md | 2 +-
docs/content/filesystems/hdfs.md | 2 +-
docs/content/filesystems/oss.md | 2 +-
docs/content/filesystems/s3.md | 2 +-
docs/content/how-to/cdc-ingestion.md | 8 ++++----
docs/content/how-to/creating-catalogs.md | 2 +-
docs/content/how-to/lookup-joins.md | 2 +-
docs/content/how-to/writing-tables.md | 2 +-
docs/content/maintenance/manage-tags.md | 4 ++--
docs/content/maintenance/rescale-bucket.md | 6 +++---
docs/layouts/shortcodes/generated/kafka_sync_database.html | 2 +-
docs/layouts/shortcodes/generated/kafka_sync_table.html | 2 +-
.../paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java | 2 +-
.../flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java | 2 +-
.../paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java | 2 +-
.../flink/action/cdc/kafka/KafkaSyncTableActionFactory.java | 2 +-
18 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/docs/content/api/flink-api.md b/docs/content/api/flink-api.md
index f2dd1f8c4..6140ba397 100644
--- a/docs/content/api/flink-api.md
+++ b/docs/content/api/flink-api.md
@@ -54,7 +54,7 @@ Please choose your Flink version.
Paimon relies on Hadoop environment, you should add hadoop classpath or bundled jar.
Paimon does not provide a DataStream API, but you can read or write to Paimon tables by the conversion between DataStream and Table in Flink.
-See [DataStream API Integration](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/data_stream_api/).
+See [DataStream API Integration](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/data_stream_api/).
## Write to Table
diff --git a/docs/content/concepts/append-only-table.md b/docs/content/concepts/append-only-table.md
index 96000c8d1..cc469019d 100644
--- a/docs/content/concepts/append-only-table.md
+++ b/docs/content/concepts/append-only-table.md
@@ -117,7 +117,7 @@ SELECT window_start, window_end, COUNT(`user`) FROM TABLE(
TUMBLE(TABLE T, DESCRIPTOR(order_time), INTERVAL '10' MINUTES)) GROUP BY window_start, window_end;
```
-You can also enable [Flink Watermark alignment](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/event-time/generating_watermarks/#watermark-alignment-_beta_),
+You can also enable [Flink Watermark alignment](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/datastream/event-time/generating_watermarks/#watermark-alignment-_beta_),
which will make sure no sources/splits/shards/partitions increase their watermarks too far ahead of the rest:
<table class="configuration table table-bordered">
diff --git a/docs/content/engines/flink.md b/docs/content/engines/flink.md
index 3cd22e9ba..8b535661b 100644
--- a/docs/content/engines/flink.md
+++ b/docs/content/engines/flink.md
@@ -262,7 +262,7 @@ The following command will used to compact a table
## Supported Flink Data Type
-See [Flink Data Types](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/types/).
+See [Flink Data Types](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/types/).
All Flink data types are supported, except that
diff --git a/docs/content/filesystems/hdfs.md b/docs/content/filesystems/hdfs.md
index 6be5af308..ace26d1a8 100644
--- a/docs/content/filesystems/hdfs.md
+++ b/docs/content/filesystems/hdfs.md
@@ -86,7 +86,7 @@ For Alluxio support add the following entry into the core-site.xml file:
{{< tab "Flink" >}}
-It is recommended to use [Flink Kerberos Keytab](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/security/security-kerberos/).
+It is recommended to use [Flink Kerberos Keytab](https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/security/security-kerberos/).
{{< /tab >}}
diff --git a/docs/content/filesystems/oss.md b/docs/content/filesystems/oss.md
index b2b53cd55..472d81f1f 100644
--- a/docs/content/filesystems/oss.md
+++ b/docs/content/filesystems/oss.md
@@ -43,7 +43,7 @@ Download [paimon-oss-{{< version >}}.jar](https://repository.apache.org/snapshot
{{< tab "Flink" >}}
{{< hint info >}}
-If you have already configured [oss access through Flink](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/filesystems/oss/) (Via Flink FileSystem),
+If you have already configured [oss access through Flink](https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/filesystems/oss/) (Via Flink FileSystem),
here you can skip the following configuration.
{{< /hint >}}
diff --git a/docs/content/filesystems/s3.md b/docs/content/filesystems/s3.md
index c7596a6c1..d1334fda8 100644
--- a/docs/content/filesystems/s3.md
+++ b/docs/content/filesystems/s3.md
@@ -43,7 +43,7 @@ Download [paimon-s3-{{< version >}}.jar](https://repository.apache.org/snapshots
{{< tab "Flink" >}}
{{< hint info >}}
-If you have already configured [s3 access through Flink](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/filesystems/s3/) (Via Flink FileSystem),
+If you have already configured [s3 access through Flink](https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/filesystems/s3/) (Via Flink FileSystem),
here you can skip the following configuration.
{{< /hint >}}
diff --git a/docs/content/how-to/cdc-ingestion.md b/docs/content/how-to/cdc-ingestion.md
index 10d2211f0..662772f5b 100644
--- a/docs/content/how-to/cdc-ingestion.md
+++ b/docs/content/how-to/cdc-ingestion.md
@@ -285,19 +285,19 @@ If a message in a Kafka topic is a change event captured from another database u
</thead>
<tbody>
<tr>
- <td><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/formats/canal/">Canal CDC</a></td>
+ <td><a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/formats/canal/">Canal CDC</a></td>
<td>True</td>
</tr>
<tr>
- <td><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/formats/debezium/">Debezium CDC</a></td>
+ <td><a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/formats/debezium/">Debezium CDC</a></td>
<td>False</td>
</tr>
<tr>
- <td><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/formats/maxwell/ >}}">Maxwell CDC</a></td>
+ <td><a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/formats/maxwell/ >}}">Maxwell CDC</a></td>
<td>False</td>
</tr>
<tr>
- <td><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/formats/ogg/">OGG CDC</a></td>
+ <td><a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/formats/ogg/">OGG CDC</a></td>
<td>False</td>
</tr>
</tbody>
diff --git a/docs/content/how-to/creating-catalogs.md b/docs/content/how-to/creating-catalogs.md
index 05d36aef8..4b09757b5 100644
--- a/docs/content/how-to/creating-catalogs.md
+++ b/docs/content/how-to/creating-catalogs.md
@@ -86,7 +86,7 @@ To use Hive catalog, Database name, Table name and Field names should be **lower
{{< tab "Flink" >}}
-Paimon Hive catalog in Flink relies on Flink Hive connector bundled jar. You should first download Flink Hive connector bundled jar and add it to classpath. See [here](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/hive/overview/#using-bundled-hive-jar) for more info.
+Paimon Hive catalog in Flink relies on Flink Hive connector bundled jar. You should first download Flink Hive connector bundled jar and add it to classpath. See [here](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/hive/overview/#using-bundled-hive-jar) for more info.
The following Flink SQL registers and uses a Paimon Hive catalog named `my_hive`. Metadata and table files are stored under `hdfs:///path/to/warehouse`. In addition, metadata is also stored in Hive metastore.
diff --git a/docs/content/how-to/lookup-joins.md b/docs/content/how-to/lookup-joins.md
index cd5655b60..620cc4a9d 100644
--- a/docs/content/how-to/lookup-joins.md
+++ b/docs/content/how-to/lookup-joins.md
@@ -85,7 +85,7 @@ ON o.customer_id = c.id;
### Retry Lookup
If the records of `Orders` (main table) join missing because the corresponding data of `customers` (lookup table) is not ready.
-You can consider using Flink's [Delayed Retry Strategy For Lookup](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#3-enable-delayed-retry-strategy-for-lookup).
+You can consider using Flink's [Delayed Retry Strategy For Lookup](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/sql/queries/hints/#3-enable-delayed-retry-strategy-for-lookup).
Only for Flink 1.16+.
```sql
diff --git a/docs/content/how-to/writing-tables.md b/docs/content/how-to/writing-tables.md
index 86b27b78f..12268e156 100644
--- a/docs/content/how-to/writing-tables.md
+++ b/docs/content/how-to/writing-tables.md
@@ -75,7 +75,7 @@ INSERT { INTO | OVERWRITE } table_identifier [ part_spec ] [ column_list ] { val
For more information, please check the syntax document:
-[Flink INSERT Statement](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/insert/)
+[Flink INSERT Statement](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/sql/insert/)
[Spark INSERT Statement](https://spark.apache.org/docs/latest/sql-ref-syntax-dml-insert-table.html)
diff --git a/docs/content/maintenance/manage-tags.md b/docs/content/maintenance/manage-tags.md
index c7e6a0913..b37fe3c15 100644
--- a/docs/content/maintenance/manage-tags.md
+++ b/docs/content/maintenance/manage-tags.md
@@ -237,7 +237,7 @@ You can set `sink.savepoint.auto-tag` to `true` to enable the feature of automat
**Step 2: Trigger savepoint.**
-You can refer to [flink savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/ops/state/savepoints/#operations)
+You can refer to [flink savepoint](https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/state/savepoints/#operations)
to learn how to configure and trigger savepoint.
**Step 3: Choose the tag corresponding to the savepoint.**
@@ -251,4 +251,4 @@ The tag corresponding to the savepoint will be named in the form of `savepoint-$
**Step 5: Restart from the savepoint.**
-You can refer to [here](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/ops/state/savepoints/#resuming-from-savepoints) to learn how to restart from a specified savepoint.
\ No newline at end of file
+You can refer to [here](https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/state/savepoints/#resuming-from-savepoints) to learn how to restart from a specified savepoint.
\ No newline at end of file
diff --git a/docs/content/maintenance/rescale-bucket.md b/docs/content/maintenance/rescale-bucket.md
index a67a4aa78..16f171635 100644
--- a/docs/content/maintenance/rescale-bucket.md
+++ b/docs/content/maintenance/rescale-bucket.md
@@ -115,8 +115,8 @@ WHERE order_status = 'verified';
The pipeline has been running well for the past few weeks. However, the data volume has grown fast recently,
and the job's latency keeps increasing. To improve the data freshness, users can
- Suspend the streaming job with a savepoint ( see
- [Suspended State](https://nightlies.apache.org/flink/flink-docs-master/docs/internals/job_scheduling/) and
- [Stopping a Job Gracefully Creating a Final Savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/cli/) )
+ [Suspended State](https://nightlies.apache.org/flink/flink-docs-stable/docs/internals/job_scheduling/) and
+ [Stopping a Job Gracefully Creating a Final Savepoint](https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/cli/) )
```bash
$ ./bin/flink stop \
--savepointPath /tmp/flink-savepoints \
@@ -149,7 +149,7 @@ and the job's latency keeps increasing. To improve the data freshness, users can
WHERE dt IN ('2022-06-20', '2022-06-21', '2022-06-22');
```
- After overwrite job has finished, switch back to streaming mode. And now, the parallelism can be increased alongside with bucket number to restore the streaming job from the savepoint
-( see [Start a SQL Job from a savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sqlclient/#start-a-sql-job-from-a-savepoint) )
+( see [Start a SQL Job from a savepoint](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/sqlclient/#start-a-sql-job-from-a-savepoint) )
```sql
SET 'execution.runtime-mode' = 'streaming';
SET 'execution.savepoint.path' = <savepointPath>;
diff --git a/docs/layouts/shortcodes/generated/kafka_sync_database.html b/docs/layouts/shortcodes/generated/kafka_sync_database.html
index 226a28e7f..ac86c6449 100644
--- a/docs/layouts/shortcodes/generated/kafka_sync_database.html
+++ b/docs/layouts/shortcodes/generated/kafka_sync_database.html
@@ -59,7 +59,7 @@ under the License.
</tr>
<tr>
<td><h5>--kafka-conf</h5></td>
- <td>The configuration for Flink Kafka sources. Each configuration should be specified in the format `key=value`. `properties.bootstrap.servers`, `topic`, `properties.group.id`, and `value.format` are required configurations, others are optional.See its <a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/table/kafka/#connector-options">document</a> for a complete list of configurations.</td>
+ <td>The configuration for Flink Kafka sources. Each configuration should be specified in the format `key=value`. `properties.bootstrap.servers`, `topic`, `properties.group.id`, and `value.format` are required configurations, others are optional.See its <a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/#connector-options">document</a> for a complete list of configurations.</td>
</tr>
<tr>
<td><h5>--catalog-conf</h5></td>
diff --git a/docs/layouts/shortcodes/generated/kafka_sync_table.html b/docs/layouts/shortcodes/generated/kafka_sync_table.html
index 91e18460b..339732e38 100644
--- a/docs/layouts/shortcodes/generated/kafka_sync_table.html
+++ b/docs/layouts/shortcodes/generated/kafka_sync_table.html
@@ -51,7 +51,7 @@ under the License.
</tr>
<tr>
<td><h5>--kafka-conf</h5></td>
- <td>The configuration for Flink Kafka sources. Each configuration should be specified in the format `key=value`. `properties.bootstrap.servers`, `topic`, `properties.group.id`, and `value.format` are required configurations, others are optional.See its <a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/kafka/#%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%8f%82%e6%95%b0">document</a> for a complete list of configurations.</td>
+ <td>The configuration for Flink Kafka sources. Each configuration should be specified in the format `key=value`. `properties.bootstrap.servers`, `topic`, `properties.group.id`, and `value.format` are required configurations, others are optional.See its <a href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/#connector-options">document</a> for a complete list of configurations.</td>
</tr>
<tr>
<td><h5>--catalog-conf</h5></td>
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
index 0b570dd7a..d9503a539 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java
@@ -47,7 +47,7 @@ import static org.apache.paimon.utils.Preconditions.checkArgument;
* An {@link Action} which synchronize the Multiple topics into one Paimon database.
*
* <p>You should specify Kafka source topic in {@code kafkaConfig}. See <a
- * href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/kafka/">document
+ * href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/">document
* of flink-connectors</a> for detailed keys and values.
*
* <p>For each Kafka topic's table to be synchronized, if the corresponding Paimon table does not
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
index 2e115e9c1..354b5405f 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
@@ -109,7 +109,7 @@ public class KafkaSyncDatabaseActionFactory implements ActionFactory {
+ "are required configurations, others are optional.");
System.out.println(
"For a complete list of supported configurations, "
- + "see https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/kafka/");
+ + "see https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/");
System.out.println();
System.out.println();
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
index 661c11d32..da6b5fb88 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
@@ -50,7 +50,7 @@ import static org.apache.paimon.flink.action.cdc.ComputedColumnUtils.buildComput
* <p>This topic must be from canal-json format.
*
* <p>You should specify Kafka source topic in {@code kafkaConfig}. See <a
- * href="https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/kafka/">document
+ * href="https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/">document
* of flink-connectors</a> for detailed keys and values.
*
* <p>If the specified Paimon table does not exist, this action will automatically create the table.
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
index 21dd3a536..0eb7c353a 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java
@@ -124,7 +124,7 @@ public class KafkaSyncTableActionFactory implements ActionFactory {
+ "are required configurations, others are optional.");
System.out.println(
"For a complete list of supported configurations, "
- + "see https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/kafka/");
+ + "see https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/kafka/");
System.out.println();
System.out.println("Paimon catalog and table sink conf syntax:");