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/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new e3249d498 [doc] Disable Flink sink.upsert-materialize
e3249d498 is described below
commit e3249d4989a425588611b7c81cf97c448acefbe7
Author: JingsongLi <[email protected]>
AuthorDate: Thu Apr 27 11:09:15 2023 +0800
[doc] Disable Flink sink.upsert-materialize
---
docs/content/concepts/primary-key-table.md | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/docs/content/concepts/primary-key-table.md
b/docs/content/concepts/primary-key-table.md
index 9a4175b1c..09cf26dc0 100644
--- a/docs/content/concepts/primary-key-table.md
+++ b/docs/content/concepts/primary-key-table.md
@@ -69,6 +69,10 @@ Partial cannot receive `DELETE` messages because the
behavior cannot be defined.
### Aggregation
+{{< hint info >}}
+NOTE: Set `table.exec.sink.upsert-materialize` to `NONE` always in Flink SQL
TableConfig.
+{{< /hint >}}
+
Sometimes users only care about aggregated results. The `aggregation` merge
engine aggregates each value field with the latest data one by one under the
same primary key according to the aggregate function.
Each field not part of the primary keys can be given an aggregate function,
specified by the `fields.<field-name>.aggregate-function` table property,
otherwise it will use `last_non_null_value` aggregation as default. For
example, consider the following table definition.