AWS managed Flink does not support setting entry class on starting a Flink app?
Read through the documentation of AWS Managed Flink, especially the “Runtime Properties” part, I do not find any mentioning about setting the main class for a given Flink jar.
Get shutdown hook for apache beam application in AWS managed apache flink
We are having a java application which uses apache beam. This is run using flink runner in AWS. After running the application, I want to update the database table. We start the batch process from lambda and I want the hook when the application is complete. I want to update the database based on that.