[jira] [Created] (FLINK-23355) Use Flink SQL ,How to implement insert into seq to multi sinks?

["Bo Wang (Jira)" <ji...@apache.org>]

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)