Fix the problem that is preventing the Avro to be the Flink serializer instead of Kyro.

j3-signalroom / apache_flink-kickstarter

Examples of Apache Flink® applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.

https://linkedin.com/in/jeffreyjonathanjennings

MIT License

1 stars 0 forks source link

Fix the problem that is preventing the Avro to be the Flink serializer instead of Kyro. #469

Closed j3-signalroom closed 1 week ago

j3-signalroom commented 1 week ago

Fixing issue record in #463 .

j3-signalroom commented 1 week ago

I created an Avro SpecificRecord Java Class to resolve the Kyro problem.

See #470