You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/03/26 07:49:00 UTC

[jira] [Created] (FLINK-16797) Flink doesn't merge multiple sinks into one DAG

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)