Request to unsubscribe

Please unsubscribe. -- Thanks and Regards Nikita Thomas

Re: Flink CDC operational questions

Hi Robin, There’s a part called “Developer Guide” in Flink CDC documentations[1] where you could find more info about how pipeline framework is implemented. Actually, Flink CDC itself does not maintain any runtime information about pipeline jobs, and it is basically equivalent to a normal Java-

Flink CDC operational questions

Are there any resources I can look at regarding the operational side of Flink CDC? e.g. is the Flink web UI the only place to monitor what's going on, or looking through the log files? Can you stop and restart a job or will it trigger a fresh snapshot? etc thanks!

Re: Flink Kubernetes Operator with Flink 1.20

Hey! You can check this WIP PR: https://github.com/apache/flink-kubernetes-operator/pull/848 There hasn't been much progress lately but maybe you can ping there or help review push it forward. Cheers, Gyula On Thu, Dec 5, 2024 at 5:12 PM Nikola Milutinovic wrote: > Hello. > > > > I am trying

Flink Kubernetes Operator with Flink 1.20

Hello. I am trying to make a deployment of Flink 1.20 session cluster using Kubernetes Operator v1.10. It looks like the operator is setting up incorrect configuration for 1.20. Namely, it is providing custom Flink configuration file as ${FLINK_HOME}/conf/flink-conf.yaml. That file path has be

Re: SavepointReader: Record size is too large for CollectSinkFunction

{ "emoji": "👍", "version": 1 }

Re: SavepointReader: Record size is too large for CollectSinkFunction

I'm intended to file a jira + PR. G On Thu, Dec 5, 2024 at 2:40 PM Salva Alcántara wrote: > So what's next? Do you want me to do something Gabor? > > Regards, > > Salva > > On Thu, Dec 5, 2024, 13:48 Gabor Somogyi > wrote: > >> Based on this I can confirm that the maxBatchSize and socketTimeo

Re: SavepointReader: Record size is too large for CollectSinkFunction

So what's next? Do you want me to do something Gabor? Regards, Salva On Thu, Dec 5, 2024, 13:48 Gabor Somogyi wrote: > Based on this I can confirm that the maxBatchSize and socketTimeout values > are coming from default value Flink config is not considered. > > G > > > On Thu, Dec 5, 2024 at 8

How to programatically register a 3rd party serializer (Flink 1.20)

I am trying to use 3rd party serializers as per https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers/ but the code sample does not compile ``` Configuration config = new Configuration(); // register the class of the se

Re: SavepointReader: Record size is too large for CollectSinkFunction

{ "emoji": "👍", "version": 1 }

Re: SavepointReader: Record size is too large for CollectSinkFunction

Based on this I can confirm that the maxBatchSize and socketTimeout values are coming from default value Flink config is not considered. G On Thu, Dec 5, 2024 at 8:20 AM Salva Alcántara wrote: > Sorry for my late reply Gabor, here you are the whole trace: > > SLF4J(W): No SLF4J providers were

Re: [External] Joining Streams: "One operator with N inputs" vs "N-1 co-processors"

Thanks a lot Matthias! Admittedly I have never used MultipleInputStraeamOperator. Will check it out! On Thu, Dec 5, 2024, 08:47 Schwalbe Matthias wrote: > Good morning Salva, > > > > The situation is much better than you apparently are aware of 😊 > > For quite some time there is an implementatio