Relative Content

Tag Archive for springspring-bootdockerapache-flinkflink-streaming

Submit flink job to jobmanger using java code and rest cluster client

I have my jobmanager and taskmanager running as docker services. In same machine, i am having other 2 microservices deployed in same docker as 2 different services (lets say MS1 and MS2). My MS1 is a spring app(not spring boot) that has pipeline creation and executeAsync code. MS2 is spring boot app, from here i want to submit my flink job to jobmanager for that wrote a rest api. Rest api’s code looks like below