Skip to content

Commit

Permalink
[Fix] Swizzles
Browse files Browse the repository at this point in the history
Signed-off-by: tison <[email protected]>
  • Loading branch information
tisonkun committed May 15, 2024
1 parent 2dd3772 commit efe0a63
Show file tree
Hide file tree
Showing 8 changed files with 48 additions and 47 deletions.
7 changes: 6 additions & 1 deletion blog/3-streampark-usercase-bondex-paimon.md
Original file line number Diff line number Diff line change
Expand Up @@ -846,13 +846,18 @@ Upon investigation, it was discovered that the issue was caused by the configura
**3. Aggregate function 'last_non_null_value' does not support retraction**

Error:

```
Caused by: java.lang.UnsupportedOperationException: Aggregate function 'last_non_null_value' does not support retraction, If you allow this function to ignore retraction messages, you can configure 'fields.${field_name}.ignore-retract'='true'.
```

An explanation can be found in the official documentation:

```
Only sum supports retraction (UPDATE_BEFORE and DELETE), other aggregate functions do not support retraction.
```

This can be understood as: except for the SUM function, other Agg functions do not support Retraction. To avoid errors when receiving DELETE and UPDATEBEFORE messages, it is necessary to configure 'fields.${field_name}.ignore-retract'='true' for the specified field to ignore retraction and solve this error.
This can be understood as: except for the SUM function, other Agg functions do not support Retraction. To avoid errors when receiving DELETE and UPDATEBEFORE messages, it is necessary to configure `'fields.${field_name}.ignore-retract'='true'` for the specified field to ignore retraction and solve this error.

```sql
WITH (
Expand Down
8 changes: 4 additions & 4 deletions community/release/How-to-release.md
Original file line number Diff line number Diff line change
Expand Up @@ -186,9 +186,9 @@ $ mvn --encrypt-master-password <apache password>
{EM+4/TYVDXYHRbkwjjAS3mE1RhRJXJUSG8aIO5RSxuHU26rKCjuS2vG+/wMjz9te}
```
- Create the file ${user.home}/.m2/settings-security.xml and configure the password created in the previous step
- Create the file `${user.home}/.m2/settings-security.xml` and configure the password created in the previous step
```shell
```xml
<settingsSecurity>
<master>{EM+4/TYVDXYHRbkwjjAS3mE1RhRJXJUSG8aIO5RSxuHU26rKCjuS2vG+/wMjz9te}</master>
</settingsSecurity>
Expand Down Expand Up @@ -242,7 +242,7 @@ $ mvn --encrypt-password <apache passphrase>
## 3. Prepare material package & release Apache Nexus
#### 3.1 Based on the dev branch, create a release-${release_version}-rcx branch, such as release-2.1.0-rc1, And create a tag named v2.1.0-rc1 based on the release-2.1.0-rc1 branch, and set this tag as pre-release.
#### 3.1 Based on the dev branch, create a `release-${release_version}-rcx` branch, such as release-2.1.0-rc1, And create a tag named v2.1.0-rc1 based on the release-2.1.0-rc1 branch, and set this tag as pre-release.
![图片](https://user-images.githubusercontent.com/19602424/236656362-1d346faa-6582-44eb-9722-8bb2de0eaa92.png)
Expand Down Expand Up @@ -409,7 +409,7 @@ apache-streampark_2.12-2.1.0-incubating-bin.tar.gz: OK
svn co --depth empty https://dist.apache.org/repos/dist/dev/incubator/streampark dist/streampark_svn_dev
```
Create a version number directory and name it in the form of ${release_version}-${RC_version}. RC_version starts from 1, that is, the candidate version starts from RC1. During the release process, there is a problem that causes the vote to fail. If it needs to be corrected, it needs to iterate the RC version , the RC version number needs to be +1. For example: Vote for version 2.1.0-RC1. If the vote passes without any problems, the RC1 version material will be released as the final version material. If there is a problem (when the streampark/incubator community votes, the voters will strictly check various release requirements and compliance issues) and need to be corrected, then re-initiate the vote after the correction, and the candidate version for the next vote is 2.1.0- RC2.
Create a version number directory and name it in the form of `${release_version}-${RC_version}`. RC_version starts from 1, that is, the candidate version starts from RC1. During the release process, there is a problem that causes the vote to fail. If it needs to be corrected, it needs to iterate the RC version , the RC version number needs to be +1. For example: Vote for version 2.1.0-RC1. If the vote passes without any problems, the RC1 version material will be released as the final version material. If there is a problem (when the streampark/incubator community votes, the voters will strictly check various release requirements and compliance issues) and need to be corrected, then re-initiate the vote after the correction, and the candidate version for the next vote is 2.1.0- RC2.
```shell
mkdir -p dist/streampark_svn_dev/2.1.0-RC1
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -846,13 +846,18 @@ set 'table.exec.sink.upsert-materialize' = 'none'
**3. Aggregate function 'last_non_null_value' does not support retraction**

报错:

```
Caused by: java.lang.UnsupportedOperationException: Aggregate function 'last_non_null_value' does not support retraction, If you allow this function to ignore retraction messages, you can configure 'fields.${field_name}.ignore-retract'='true'.
```

可以在官方文档找到解释:

```
Only sum supports retraction (UPDATE_BEFORE and DELETE), others aggregate functions do not support retraction.
```

可以理解为:除了 SUM 函数,其他的 Agg 函数都不支持 Retraction,为了避免接收到 DELETE 和 UPDATEBEFORE 消息报错,需要通过给指定字段配 'fields.${field_name}.ignore-retract'='true' 忽略,解决这个报错
可以理解为:除了 SUM 函数,其他的 Agg 函数都不支持 Retraction,为了避免接收到 DELETE 和 UPDATEBEFORE 消息报错,需要通过给指定字段配 `'fields.${field_name}.ignore-retract'='true'` 忽略,解决这个报错

```sql
WITH (
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -186,9 +186,9 @@ $ mvn --encrypt-master-password <apache password>
{EM+4/TYVDXYHRbkwjjAS3mE1RhRJXJUSG8aIO5RSxuHU26rKCjuS2vG+/wMjz9te}
```
- 创建文件 ${user.home}/.m2/settings-security.xml 并配置上一步创建的密码
- 创建文件 `${user.home}/.m2/settings-security.xml` 并配置上一步创建的密码
```shell
```xml
<settingsSecurity>
<master>{EM+4/TYVDXYHRbkwjjAS3mE1RhRJXJUSG8aIO5RSxuHU26rKCjuS2vG+/wMjz9te}</master>
</settingsSecurity>
Expand Down Expand Up @@ -242,7 +242,7 @@ $ mvn --encrypt-password <apache passphrase>
## 3. 准备物料 & 发布到Apache Nexus
#### 3.1 基于dev分支,创建一个名为release-${release_version}-rcx的分支,例如release-2.1.0-rc1。并基于release-2.1.0-rc1分支创建一个名为v2.1.0-rc1的标签,并将此标签设置为预发布。
#### 3.1 基于 dev 分支,创建一个名为 `release-${release_version}-rcx` 的分支,例如 release-2.1.0-rc1。并基于 release-2.1.0-rc1 分支创建一个名为 v2.1.0-rc1 的标签,并将此标签设置为预发布。
![图片](https://user-images.githubusercontent.com/19602424/236656362-1d346faa-6582-44eb-9722-8bb2de0eaa92.png)
Expand Down Expand Up @@ -409,7 +409,7 @@ apache-streampark_2.12-2.1.0-incubating-bin.tar.gz: OK
svn co --depth empty https://dist.apache.org/repos/dist/dev/incubator/streampark dist/streampark_svn_dev
```
创建一个版本号目录,并以${release_version}-${RC_version}的形式命名。RC_version从1开始,即候选版本从RC1开始。在发布过程中,如果出现导致投票失败的问题,需要进行修正,那么RC版本需要迭代,RC版本号需要+1。例如:为版本2.1.0-RC1投票。如果投票顺利通过,那么RC1版本的资料将作为最终版本的资料发布。如果出现问题(当streampark/incubator社区进行投票时,投票者会严格检查各种发布要求和合规问题)并需要纠正,那么修正后重新启动投票,下一次的候选版本为2.1.0-RC2。
创建一个版本号目录,并以 `${release_version}-${RC_version}` 的形式命名。RC_version从1开始,即候选版本从RC1开始。在发布过程中,如果出现导致投票失败的问题,需要进行修正,那么RC版本需要迭代,RC版本号需要+1。例如:为版本2.1.0-RC1投票。如果投票顺利通过,那么RC1版本的资料将作为最终版本的资料发布。如果出现问题(当streampark/incubator社区进行投票时,投票者会严格检查各种发布要求和合规问题)并需要纠正,那么修正后重新启动投票,下一次的候选版本为2.1.0-RC2。
```shell
mkdir -p dist/streampark_svn_dev/2.1.0-RC1
Expand Down
22 changes: 11 additions & 11 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -23,29 +23,29 @@
"@docusaurus/theme-mermaid": "3.3.2",
"@docusaurus/utils-common": "3.3.2",
"@easyops-cn/docusaurus-search-local": "^0.36.0",
"@mdx-js/react": "^1.6.22",
"@svgr/webpack": "^6.2.1",
"@mdx-js/react": "^3.0.1",
"@svgr/webpack": "^6.5.1",
"aos": "^2.3.4",
"clsx": "^1.2.1",
"file-loader": "^6.2.0",
"framer-motion": "^10.13.1",
"framer-motion": "^10.18.0",
"[email protected]": "link:docusaurus/[email protected]",
"prism-react-renderer": "^1.3.1",
"prismjs": "^1.28.0",
"react": "^18.2.0",
"prism-react-renderer": "^1.3.5",
"prismjs": "^1.29.0",
"react": "^18.3.1",
"react-copy-to-clipboard": "^5.1.0",
"react-dom": "^18.2.0",
"react-dom": "^18.3.1",
"react-tsparticles": "^2.12.2",
"sass-loader": "^13.0.2",
"sass-loader": "^13.3.3",
"url-loader": "^4.1.1"
},
"devDependencies": {
"@docusaurus/module-type-aliases": "2.4.3",
"@tsconfig/docusaurus": "^1.0.4",
"@tsconfig/docusaurus": "^1.0.7",
"docusaurus-plugin-less": "^2.0.2",
"less": "^4.1.2",
"less": "^4.2.0",
"less-loader": "^10.2.0",
"typescript": "^4.5.5"
"typescript": "^4.9.5"
},
"browserslist": {
"production": [
Expand Down
32 changes: 12 additions & 20 deletions pnpm-lock.yaml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 2 additions & 3 deletions src/theme/DocCard/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,9 @@ import React from 'react';
import clsx from 'clsx';
import Link from '@docusaurus/Link';
import {
findFirstCategoryLink,
findFirstSidebarItemLink,
useDocById,
} from '@docusaurus/theme-common/internal';
import isInternalUrl from '@docusaurus/isInternalUrl';
import {translate} from '@docusaurus/Translate';
import styles from './styles.module.css';
function CardContainer({href, children}) {
Expand Down Expand Up @@ -34,7 +33,7 @@ function CardLayout({href, icon, title, description}) {
);
}
function CardCategory({item}) {
const href = findFirstCategoryLink(item);
const href = findFirstSidebarItemLink(item);
// Unexpected: categories that don't have a link have been filtered upfront
if (!href) {
return null;
Expand Down
6 changes: 3 additions & 3 deletions src/theme/DocSidebarItem/Category/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import {
} from '@docusaurus/theme-common';
import {
isActiveSidebarItem,
findFirstCategoryLink,
findFirstSidebarItemLink,
useDocSidebarItemsExpandedState,
isSamePath,
} from '@docusaurus/theme-common/internal';
Expand Down Expand Up @@ -44,11 +44,11 @@ function useCategoryHrefWithSSRFallback(item) {
return item.href;
}
// In these cases, it's not necessary to render a fallback
// We skip the "findFirstCategoryLink" computation
// We skip the "findFirstSidebarItemLink" computation
if (isBrowser || !item.collapsible) {
return undefined;
}
return findFirstCategoryLink(item);
return findFirstSidebarItemLink(item);
}, [item, isBrowser]);
}
function CollapseButton({categoryLabel, onClick}) {
Expand Down

0 comments on commit efe0a63

Please sign in to comment.