ctSink.values.clear();
>
> List listOfNumbers = IntStream.rangeClosed(1,
> inputSize).boxed().collect(Collectors.toList());
>
> // 1st half of pipeline
> //DataStream> pipeA = env.fromCollection(listOfNumbers)
> DataStream> pipeA = env.addSource(new
> St
e...)
From: Biao Liu
Sent: Tuesday 17 December 2019 21:50
To: John Morrow
Cc: user
Subject: Re: MiniCluster with ProcessingTimeTrigger
Hi John,
The root cause is the collection source exits too fast. The window would also
exit without being triggered.
You c
Hi John,
The root cause is the collection source exits too fast. The window would
also exit without being triggered.
You could verify that by waiting a second before releasing the window. For
example, insert a map operator between source and window operator. Blocking
a second or more in the "clos
