Hi,
yes, you can remove the line with the trigger.
Here is a version of the code without the trigger:
https://github.com/rmetzger/scratch/blob/flink0.10-scala2.11/src/main/scala/com/dataartisans/JobWithoutTrigger.scala
On Fri, Nov 13, 2015 at 11:29 AM, Kamil Gorlo wrote:
> OK, so as far as I und
OK, so as far as I understand the line ".trigger(new EOFTrigger)" is simply
not needed in this case (it looks that it works as expected when I remove
it).
Thanks for your help.
pt., 13.11.2015 o 11:01 użytkownik Robert Metzger
napisał:
> Hi Kamil,
>
> The EOFTrigger is not part of Flink.
> Howe
Hi Kamil,
The EOFTrigger is not part of Flink.
However, I've also tried implementing the Hello World from the presentation
here:
https://github.com/rmetzger/scratch/blob/flink0.10-scala2.11/src/main/scala/com/dataartisans/Job.scala
Stephan Ewen told me that there is a more elegant way of implemen