[
https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007720#comment-18007720
]
Shuai Xu edited comment on FLINK-38029 at 7/17/25 6:14 AM:
-----------------------------------------------------------
I have conducted cross testing on FLIP-486, and the verification steps are as
follows:
1. Checkout and compile flink in commit branch: release-2.1.
2. Compile fluss using g...@github.com:Au-Miner/fluss.git with branch=flink2.1
into Flink's lib.
3. Start fluss server in standalone mode.
4. Start a standalone flink cluster and launch the SQL client.
5. prepare two temporary tables with datagen connector and two fluss catalog
table.
6. insert the data generated from temporary tables to fluss catalog table as
source tables.
7. create two fluss catalog tables as sink tables.
8. insert into one of sink tables througn join operation using source tables.
9. set 'table.optimizer.delta-join.strategy' = 'force'.
10. insert into another sink table througn the same join operation using source
tables by check the flink ui it contains delta join operator.
11. check the two sink tables if they are the same and they are.
After following the above steps, the result appears to be correct.
was (Author: JIRAUSER300096):
I have conducted cross testing on FLIP-486, and the verification steps are as
follows:
1. Checkout and compile flink in commit branch: release-2.1.
2. Compile fluss using g...@github.com:Au-Miner/fluss.git with branch=flink2.1
into Flink's lib.
3. Start fluss server in standalone mode.
4. Start a standalone flink cluster and launch the SQL client.
5. prepare two temporary tables with datagen connector and two fluss catalog
table.
6. insert the data generated from temporary tables to fluss catalog table as
source tables.
7. create two fluss catalog tables as sink tables.
8. insert into one of sink tables througn join operation using source tables.
9. set 'table.optimizer.delta-join.strategy' = 'force'.
10. insert into another sink table througn the same join operation using source
tables by check the flink ui it contains delta join operator.
11. check the two sink tables if they are the same and they are.
As above steps, it shows the result is correct.
> Release Testing: Verify FLIP-486: Introduce a new DeltaJoin
> -----------------------------------------------------------
>
> Key: FLINK-38029
> URL: https://issues.apache.org/jira/browse/FLINK-38029
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner, Table SQL / Runtime
> Affects Versions: 2.1.0
> Reporter: Xuyang Zhong
> Priority: Blocker
> Fix For: 2.1.0
>
>
> Follow up the test for https://issues.apache.org/jira/browse/FLINK-37836
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
