Re: [Issue] Failure on stopping Flink(1.17) application

2023-08-19 Thread liu ron
Hi, I think you can check the client side and JobManager side log to get more info. Best, Ron Dennis Jung 于2023年8月18日周五 10:41写道: > Hello people, > > I'm facing failure when I try to stop running Flink job with REST API > 'jobs/:jobid/stop' > > ``` > ... > java.util.concurrent.CompletionExcepti

TaskManagers Crushing

2023-08-19 Thread Kenan Kılıçtepe
Hi, I have 4 task manager working on 4 servers. They all crush at the same time without any useful error logs. Only log I can see is some disconnection from Kafka for both consumer and producers. Any idea or any help is appreciated. Some logs from all taskmanagers: I think first server 4 is crus

Re: Flink AVRO to Parquet writer - Row group size/Page size

2023-08-19 Thread Feng Jin
Hi Kamal I think it depends on the amount of data and the usage scenario. If your checkpoint interval is very long, multiple row groups may be written within one checkpoint cycle, so configuring the row group size makes sense. However, if there are short intervals between checkpoints or if you hav

RE: Flink AVRO to Parquet writer - Row group size/Page size

2023-08-19 Thread Kamal Mittal via user
Hello Community, Please help me to find out inputs for below query. Rgds, Kamal From: Kamal Mittal via user Sent: 18 August 2023 08:04 AM To: user@flink.apache.org Subject: RE: Flink AVRO to Parquet writer - Row group size/Page size Hello Community, Please share views for below. Rgds, Kamal