Query regarding akka.framesize in Flink

ytes" Flink is getting started perfectly would any error if this akka.framesize is set to 1 gb. My queries are : 1. Is there any limit for setting the value of akka.framesize. 2. Are there any dependent parameters that we need to set if we increase the size of akka.framesize. Thanks in adva

Re: Query regarding ClassCastException

Hi Team, Just a follow up mail regarding the query. Any leads would be appreciated. Thanks and Regards Mahima Agarwal On Mon, Mar 21, 2022 at 2:56 PM Mahima Agarwal wrote: > Hi Team, > > I am getting a ClassCastException in my flink job's business logic when > using the be

Query regarding ClassCastException

s per the solution mentioned in the document we could not package the avro jar in the job, we can only add the avro jar to the Flink /lib folder. Is there any way we can clear the cache in Avro or any other way we can solve this? Any leads would be appreciated. Thanks and Regards Mahima Agarwal

Query regarding Kafka Source and Kafka Sink in 1.14.3

on for this warning? Also, in flink version 1.13.2 we were able write timestamp to kafka using setWriteTimestampToKafka(true) method of FlinkKafkaProducer class. Similar to this how can we write timestamp to kafka using KafkaSink API in flink 1.14.3? Any leads would be appreciated. Thanks and Regards Mahima Agarwal

Re: Query regarding exceptions API(/jobs/:jobid/exceptions)

k logs? That > would make it easier to investigate the problem. > > Best, > Matthias > > On Sun, Nov 28, 2021 at 7:29 AM Mahima Agarwal > wrote: > >> Thanks Matthias >> >> But we have observed the below 2 exceptions are coming in root-exceptions

Re: Query regarding exceptions API(/jobs/:jobid/exceptions)

s\abc\Documents\checkpoints\a737088e21206281db87f6492bcba074' on file system 'file'. Caused by: java.lang.IllegalStateException: Failed to rollback to checkpoint/savepoint file:/mnt/c/Users/abc/Documents/checkpoints/a737088e21206281db87f6492bcba074/chk-144. Thanks and Regards Mahima A

Query regarding exceptions API(/jobs/:jobid/exceptions)

Hi Team, Please find the query below regarding exceptions API(/jobs/:jobid/exceptions) In response of above rest api: Users are getting 3 types of exceptions: 1. exceptionHistory 2. all-exceptions 3. root-exception What is the purpose of the above 3 exceptions? Any leads would be appreciat

Issue while using parallelism.default in flink-conf.yaml file

Hi Team, Please find the query below. Use Case: Using parallelism.default property mentioned in flink-conf.yaml file to enable system-level parallelism in flink configuration. Issue: Even after setting the parallelism.default to 3, on config start the configuration starts with parallelism as 1.