[
https://issues.apache.org/jira/browse/FLINK-38074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004203#comment-18004203
]
xiangyu feng edited comment on FLINK-38074 at 7/9/25 3:53 PM:
--------------------------------------------------------------
# `build-target/bin/start-cluster.sh` from 2.1 branch build to start Flink
cluster
# `build-target/bin/sql-client.sh` from 2.1 branch build to start Sql client
# execute following DDLs to create temp table
{code:java}
CREATE TABLE print_table (pk STRING, t1 STRING)
WITH ('connector' = 'print');
CREATE TEMPORARY TABLE word_table1 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1');
CREATE TEMPORARY TABLE word_table2 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1');
CREATE TEMPORARY TABLE word_table3 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1'); {code}
4. execute following DMLs to submit insert job
{code:java}
EXECUTE STATEMENT SET
BEGIN
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table1;
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table2;
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table3;
END; {code}
5. open flink UI at [http://localhost:8081/#/overview], the job DAG
should be like:
!image-2025-07-09-23-52-55-324.png!
was (Author: JIRAUSER301129):
# `build-target/bin/start-cluster.sh` from 2.1 branch build to start Flink
cluster
# `build-target/bin/sql-client.sh` from 2.1 branch build to start Sql client
# execute following DDLs to create temp table
{code:java}
CREATE TABLE print_table (pk STRING, t1 STRING)
WITH ('connector' = 'print');
CREATE TEMPORARY TABLE word_table1 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1');
CREATE TEMPORARY TABLE word_table2 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1');
CREATE TEMPORARY TABLE word_table3 (pk STRING, t1 STRING)
WITH ('connector' = 'datagen', 'rows-per-second' = '1'); {code}
# execute following DMLs to submit insert job
{code:java}
EXECUTE STATEMENT SET
BEGIN
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table1;
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table2;
INSERT INTO print_table(pk, t1)
SELECT pk,
t1
FROM word_table3;
END; {code}
# open flink UI at [http://localhost:8081/#/overview], the job DAG should be
like:
!image-2025-07-09-23-52-55-324.png!
> Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in
> Planner
> -------------------------------------------------------------------------------
>
> Key: FLINK-38074
> URL: https://issues.apache.org/jira/browse/FLINK-38074
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: xiangyu feng
> Priority: Major
> Labels: release-testing
> Attachments: image-2025-07-09-23-52-55-324.png
>
>
> Follow up the test for https://issues.apache.org/jira/browse/FLINK-37227
>
> h4.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
