Java 11 Classic FlinkRunner Gradle (ShadowJar) I'm fairly new and attempting to use the flink runner, but when I submit the job in detached mode flink throws an exception. This only happens when the flink version is >= 1.16.
This is a very simple pipeline with a create.of(). Running this with flink 1.15 did not throw an exception. Caused by: org.apache.flink.api.common.InvalidProgramException: Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available. Any help or guidance would be greatly appreciated. Dependency? Shading? Options? The goal would be to run this within Managed Flink in AWS. Sincerely
