flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Luis Mariano Guerra <mari...@event-fabric.com>
Subject Re: Side effects or multiple sinks on streaming jobs?
Date Wed, 26 Oct 2016 08:27:03 GMT
do I have to send the errors "in band"?

that is, return maybe more than one tuple in my operations then flatmap and
use a KeyedSerializationSchema?

or is there a way to emit a tuple to another sink from within operations
directly?

On Wed, Oct 26, 2016 at 9:20 AM, Robert Metzger <rmetzger@apache.org> wrote:

> Hi Luis,
>
> You can define as many data sinks as you want in a Flink job topology.
> So its not a problem for your use case to define two Kafka sinks, sending
> data to different topics.
>
> Regards,
> Robert
>
>
> On Tue, Oct 25, 2016 at 3:30 PM, Luis Mariano Guerra <
> mariano@event-fabric.com> wrote:
>
>> hi,
>>
>>  I'm migrating some samza jobs to flink streaming, and on samza we sent
>> the errors to a kafka topic to make it easier to display on dashboards, I
>> would like to do the same on flink, what do you recommend?
>>
>>
>>
>

Mime
View raw message