Re: Reducing Checkpoint Count for Chain Operator

2023-02-01 Thread Kishore Pola
Hi Weijie, In our case we do have 7 operators. All the 7 operators are getting executed as one chain within a single StreamTask. As checkpoint barrier is passing through all the operators, there are 7 checkpoints being stored. So our checkpoint size is up by 7 times. We are investigating to see

Re: HTTP 404 while creating resource with flink kubernetes operator and frabric8 client

2022-06-23 Thread Kishore Pola
+ UTC deployed flink-kubernetes-operator-1.0.0 1.0.0 Here are the screenshots showing the running operator. Thanks, Kishore From: Yang Wang Sent: Thursday, June 23, 2022 2:30 AM To: yu'an huang Cc: Kishore Pola ; user@flink.apache.org Subject: Re: HTT

HTTP 404 while creating resource with flink kubernetes operator and frabric8 client

2022-06-22 Thread Kishore Pola
Hello flink user group, When I am trying to create a flink deployment with the operator programmatically, kubernetes cluster is returning HTTP 404 message. Any pointers/help? I am constructing the context using fabric8 client like this Config config = new ConfigBuilder()