Jeff Zhang created FLINK-16797:
----------------------------------
Summary: Flink doesn't merge multiple sinks into one DAG
Key: FLINK-16797
URL: https://issues.apache.org/jira/browse/FLINK-16797
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.10.0
Reporter: Jeff Zhang
Here's sql I used.
{code:java}
insert into sink_kafka select status, direction, cast(event_ts/1000000000 as
timestamp(3)) from source_kafka where status <> 'foo';
insert into sink_kafka2 select status, direction, cast(event_ts/1000000000 as
timestamp(3)) from source_kafka where status <> 'foo';
{code}
Ideally flink should run these 2 sql as one dag with 2 sinks, but what I see is
that flink won't merge them into one dag.
!https://cdn-images-1.medium.com/max/1760/1*mFu6OZivrfGUgu1UVCcy6A.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
