[
https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930508#comment-17930508
]
Shuai Xu commented on FLINK-37068:
----------------------------------
Hi, [~xuyangzhong]. I have tested this according to the instruction.
1. checkout and compile flink in commit hash: fb4d6624
2. start a standlone flink cluster
3. Modify filesystem connector to make it accept all changelog mode and each
rowkind of input is modified as INSERT, then replace the
flink-connector-files-2.0-SNAPSHOT.jar in lib with new jar.
4. start a sql-client and execute statements. Using 'set
'table.exec.async-state.enabled' = 'true'.' and 'set
'table.optimizer.agg-phase-strategy' = 'ONE_PHASE'' to set necessary conf.
5. check the log in TM to confirm the async state operator is used.
6. Check if the results of sync state operator and async state operator are
completely identical. These results are indeed consistent.
> Cross-team verification for FLIP-473
> ------------------------------------
>
> Key: FLINK-37068
> URL: https://issues.apache.org/jira/browse/FLINK-37068
> Project: Flink
> Issue Type: Sub-task
> Reporter: Xintong Song
> Assignee: Shuai Xu
> Priority: Blocker
> Fix For: 2.0.0
>
>
> This is for cross-team verification of the release 2.0 work item: FLIP-473
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-473+Introduce+New+SQL+Operators+Based+on+Asynchronous+State+APIs
> Please complete the following steps before Jan 31.
> # Replace the description of the ticket with instructions for the testers.
> ** If the work item does not need cross-team verification, please comment
> that explicitly and close the ticket.
> # Un-assign yourself after adding the instructions.
> # Either find a cross-team tester who is willing to help and assign to the
> ticket, or reach out to the release manager [~xtsong].
> Thanks for your contributions. For any questions, feel free to reach out to
> the release manager [~xtsong].
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
