Bo Wang created FLINK-23355:
-------------------------------
Summary: Use Flink SQL ,How to implement insert into seq to multi
sinks?
Key: FLINK-23355
URL: https://issues.apache.org/jira/browse/FLINK-23355
Project: Flink
Issue Type: Technical Debt
Components: Table SQL / API
Affects Versions: 1.12.0
Reporter: Bo Wang
Now, I want to use Flink SQL implement insert to multi sinks in seq， such as I
have one Kafka Table source_table_one and have two sink table , db table
sink_db_one, kafka table sink_kafka_two.
I want to implement when the element from source_table_one arriavd, first
insert into table sink_db_one select * from source_table_one when element be
inserted, second stage insert into table sink_kafka_two select * from
source_table_one。
the web system will listen the sink_kafka_two topic and query data from
sink_db_one table.
anyone have some idea to implement this function ?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
