[
https://issues.apache.org/jira/browse/FLINK-16797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067678#comment-17067678
]
Jeff Zhang commented on FLINK-16797:
------------------------------------
Thanks [~godfreyhe] & [~jark]
> 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
> Priority: Major
>
> 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)
