Hi Narasimha,
I think without a major change in vvp it will not be possible to submit
multiple jobs within one jar in the foreseeable future. Maybe you can explain
more about your use case why it is inconvenient for you to put the jobs in
multiple jars?
With ververica platform 2.4 we will add supp
Thanks for the information.
Are there any plans to implement this? It is supported on other docker
images...
On Tue, 8 Dec 2020 at 9:36 PM, Fabian Paul
wrote:
> Hi Narasimha,
>
> I investigated your problem and it is caused by multiple issues. First vvp
> in
> general cannot really handle multi
Hi Narasimha,
I investigated your problem and it is caused by multiple issues. First vvp in
general cannot really handle multi job submissions per jar because the complete
deployment lifecycle in vvp is scoped around a single Flink job id.
Therefore vvp sets a generated Flink job id during submiss
thanks Fabian for responding.
flink image : registry.ververica.com/v2.2/flink:1.11.1-stream1-scala_2.12
There are no errors as such. But it is just considering the first job.
On Thu, Dec 3, 2020 at 5:34 PM Fabian Paul
wrote:
> Hi Narasimha,
>
> Nothing comes to my mind immediately why it shou
Hi Narasimha,
Nothing comes to my mind immediately why it should not work. We are using the
StandaloneApplicationClusterEntryPoint to start the cluster. Can you provide
some more information about which Flink image on vvp are you trying to use and
maybe show the error message?
Best,
Fabian
Hi Narasimha,
thanks for reaching out to the community. I am not entirely sure whether
VVP 2.3 supports the application mode. Since this is a rather new feature,
it could be that it has not been integrated yet. I am pulling in Ufuk and
Fabian who should be able to definitely answer your question.
Hi,
Using ververica platform to deploy flink jobs, found that it is not
supporting application deployment mode.
Just want to check if it is expected.
Below is a brief of how the main method has been composed.
class Job1 {
public void execute(){
StreamExecutingEnvironemnt env = ...
