Hi, vino:
Thanks for your answer. When I set 20 parallelism, I can run job succeed
every time. When setting 40 parallelism, sometimes I can submit it
successfully, sometimes throw the exception. When setting 60 parallelism at the
time, it has not been submitted successfully, always this exception.So I don't
think it has anything to do with my program.
在 2019-11-07 15:20:13，"vino yang" <yanghua1...@gmail.com> 写道：
Hi mailtolrl,
Can you share more context about your program and UDAF.
Best,
Vino
mailtolrl <mailto...@126.com> 于2019年11月7日周四 下午3:05写道：
My flink streaming job use a udaf, set 60 parallelisms，submit job in yarn
cluster mode，and then happens every time I start.
