Hi Team,
I am getting a ClassCastException in my flink job's business logic when
using the below code to clone an object with newBuilder.
MyClass outEvent = new MyClass();
outEvent = (MyClass) MyClass.newBuilder(inEvent).build();
Exception : Caused by: java.lang.ClassCastException:
com.avro.mon.
Hi Team,
Just a follow up mail regarding the query.
Any leads would be appreciated.
Thanks and Regards
Mahima Agarwal
On Mon, Mar 21, 2022 at 2:56 PM Mahima Agarwal
wrote:
> Hi Team,
>
> I am getting a ClassCastException in my flink job's business logic when
> using the below code to clone
Hi Mahima,
have you checked whether the problematic dependency (seems to be avro) is
contained in Flink's /lib folder in your case? I would suggest to check on
JobManagers and TaskManagers, since you say it's in the business logic.
Have you tried the suggestions mentioned in the docs? Those would
