When using udaf, the startup job has a “Cannot determine simple type name 'com' ” exception(Flink version 1.7.2)
My flink streaming job use a udaf, set 60 parallelisms,submit job in yarn cluster mode,and then happens every time I start.
Re:Re: When using udaf, the startup job has a “Cannot determine simple type name 'com' ” exception(Flink version 1.7.2)
exception.So I don't think it has anything to do with my program. 在 2019-11-07 15:20:13,"vino yang" 写道: Hi mailtolrl, Can you share more context about your program and UDAF. Best, Vino mailtolrl 于2019年11月7日周四 下午3:05写道: My flink streaming job use a udaf, set 60 parallel