Thanks, I'll check it out. Actually I realized I can always put a filter operator that'll effectively remove everything from the stream.
-- Dmitry On Thu, Oct 24, 2019 at 2:29 AM vino yang <yanghua1...@gmail.com> wrote: > Hi Dmitry, > > Perhaps an easy way is to customize a source function. Then in the run > method, start an empty loop? But I don't understand the meaning of starting > a stream pipeline without generating data. > > Best, > Vino > > Dmitry Minaev <mina...@gmail.com> 于2019年10月24日周四 上午6:16写道： > >> Hi everyone, >> >> I have a pipeline where I union several streams. I want to test it and >> don't >> want to populate one of the streams. I'm usually creating streams with: >> >> DataStreamTestBase.createTestStreamWith(event).close(); >> >> The above statement creates a stream and puts the `event` inside. But in >> my >> case I want to create an empty stream. >> >> How do I do it? >> >> -- >> Thanks, Dmitry >> >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> >
