ix, and for any additional answer :)
Best regards,
Teodor
On Sun, Aug 30, 2020 at 12:29:31PM +0200, Teodor Spæren wrote:
Hey David!
I tried what you said, but it did not solve the problem. The job still
has to wait until the very end before outputting anything.
I mentioned in my original email tha
llelism of the source to 1, like this
final DataStream linesIn =
env.readTextFile(fileNameInput).setParallelism(1);
then you should see the job make steady forward progress with windows
closing on a regular basis.
Regards,
David
On Sat, Aug 29, 2020 at 4:59 PM Teodor Spæren
wrote:
He
;
praps.window(TumblingEventTimeWindows.of(Time.hours(1))).sum("something").print("JAJ!");
env.execute("FlinkWikipediaHistoryTopEditors");
}
}
If you see any erors here, please tell me, this is sort of driving me
mad >_<.
Best regards,
Teodor Spæren
[1] https://github.com/rHermes/flink-question-001
