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
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
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
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