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/ >
