Hi Victor, Currently, it seems the "side output" feature does not been supported by the streaming sink.
IMO, you can customize your sink via selecting different types of events to output to different places. WDYT? Best, Vino Victor Villa Dev <victor.villa....@gmail.com> 于2019年11月25日周一 下午1:37写道： > Hi Vino, > > Thanks a lot for your reply! > However I'm not quite sure my question was clear enough. > I'm aware I can create/get side outputs using output tags from within > operators (Process Functions) as documentation also states. > > The main point in my question is wether creating a sideo output is even > possible from within a Sink? > if so, would you mind pointing to an examples on how to correctly get the > context necessary to add the "output" from within the "invoke()" method. > In case it isn't what are the usual/suggested strategies? > > I know the Sink is usually the "last" portion of a data stream as its name > indicates, but I was wondering if for some reason something can't be sinked > (after retries, etc), what is the usual way to deal with such cases? > > Thanks again for your kind support. > > On 2019/11/25 02:23:15, vino yang <yanghua1...@gmail.com> wrote: > > Hi Victor, > > > > Firstly, you can get your side output stream via OutputTag. Please refer > to > > the official documentation[1]. > > Then, specify a sink for your side output stream. Of course, you can > > specify a Kafka sink. > > > > Best, > > Vino > > > > [1]: > > > https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html > > > > Victor Villa Dev <victor.villa....@gmail.com> 于2019年11月25日周一 上午2:27写道： > > > > > I'd like know if there's a way to generate a side output and/or sink > to an > > > alternate kafka topic from within a Sink? > > > The use case is the datastream sinks to a storage and on particular > failed > > > attempts I'd like to deadletter to a kafka topic. > > > Any suggestions? > > > > > > Thanks > > > > > >
