This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new 77b4a085 [FLINK-31287]Modify the default value of
changelog-producer.compaction-interval to 0s
77b4a085 is described below
commit 77b4a085424e446863b6d2e4464b4689898d51d5
Author: xzw_deepnova <[email protected]>
AuthorDate: Tue Mar 7 10:56:49 2023 +0800
[FLINK-31287]Modify the default value of
changelog-producer.compaction-interval to 0s
This closes #577
---
docs/content/docs/concepts/primary-key-table.md | 2 +-
docs/layouts/shortcodes/generated/core_configuration.html | 2 +-
.../org/apache/flink/table/store/connector/FlinkConnectorOptions.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/content/docs/concepts/primary-key-table.md
b/docs/content/docs/concepts/primary-key-table.md
index 420bb068..84d20247 100644
--- a/docs/content/docs/concepts/primary-key-table.md
+++ b/docs/content/docs/concepts/primary-key-table.md
@@ -150,7 +150,7 @@ If your input can’t produce a complete changelog but you
still want to get rid
By specifying `'changelog-producer' = 'full-compaction'`, Table Store will
compare the results between full compactions and produce the differences as
changelog. The latency of changelog is affected by the frequency of full
compactions.
-By specifying `changelog-producer.compaction-interval` table property (default
value `30min`), users can define the maximum interval between two full
compactions to ensure latency. This table property does not affect normal
compactions and they may still be performed once in a while by writers to
reduce reader costs.
+By specifying `changelog-producer.compaction-interval` table property (default
value `0s`), users can define the maximum interval between two full compactions
to ensure latency. This is set to 0 by default, so each checkpoint will have a
full compression and generate a change log.
{{< img src="/img/changelog-producer-full-compaction.png">}}
diff --git a/docs/layouts/shortcodes/generated/core_configuration.html
b/docs/layouts/shortcodes/generated/core_configuration.html
index 442c68b7..c8cf7ced 100644
--- a/docs/layouts/shortcodes/generated/core_configuration.html
+++ b/docs/layouts/shortcodes/generated/core_configuration.html
@@ -34,7 +34,7 @@
</tr>
<tr>
<td><h5>changelog-producer.compaction-interval</h5></td>
- <td style="word-wrap: break-word;">30 min</td>
+ <td style="word-wrap: break-word;">0 ms</td>
<td>Duration</td>
<td>When changelog-producer is set to FULL_COMPACTION, full
compaction will be constantly triggered after this interval.</td>
</tr>
diff --git
a/flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java
b/flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java
index a4bbd0df..722bebff 100644
---
a/flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java
+++
b/flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java
@@ -102,7 +102,7 @@ public class FlinkConnectorOptions {
public static final ConfigOption<Duration>
CHANGELOG_PRODUCER_FULL_COMPACTION_TRIGGER_INTERVAL =
key("changelog-producer.compaction-interval")
.durationType()
- .defaultValue(Duration.ofMinutes(30))
+ .defaultValue(Duration.ofSeconds(0))
.withDescription(
"When "
+ CoreOptions.CHANGELOG_PRODUCER.key()
