I created a keystore with
and adapted flink-conf.yaml to point to this with the following configuration:
Now I know that this setup is supposed to work with Flink 1.6+ but probably wrong for 1.5. However, I was able to start up a Flink cluster and tried to submit a job via
and nothing happened. The CLI was stuck at
and the job did not show up in the Web UI. I can also not find anything related to the job submission in the JM log.
Debugging into CliFrontend, it eventually enters RestClient#submitRequest but doesn't seem to get a response. RestClient.MultipartRequest#writeTo does add a listener on the future and debugging in there, the ignored object handed to the lambda is a DefaultChannelPromise@1a884b08(failure(java.nio.channels.ClosedChannelException) which looks like we should react on. However, that alone is not really enough information on the cause of the error and requires further investigation.