multiple requests on the same task, but it
may be acceptable, especially if I go with AsyncIO
* or I can go with the OperatorState and implements my own firing logic
o I am in a case where the memory-based mechanism should be fine
Thanks again,
Regards.
Julien.
On 20/02/2018 02:48
and forget my custom partitioner ?
Thanks again for your feedback,
Julien.
On 19/02/2018 03:45, 周思华 wrote:
Hi Julien,
If I am not misunderstand, I think you can key your stream on a
`Random.nextInt() % parallesm`, this way you can "group" together
alerts from different and benefi
nd 3 (so 2
over my 4 operators will not have anything to do)
So, what will be the best way to deal with that?
Thank you in advance for your support.
Regards.
Julien.
