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 <[email protected]>
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:");
