Hi, Lei.
It's indeed a bit confusing. Could you share the related rocksdb log which
may contain more detailed info ?
On Fri, Apr 12, 2024 at 12:49 PM Lei Wang wrote:
>
> I enable RocksDB native metrics and do some performance tuning.
>
> state.backend.rocksdb.block.cache-size is set to 128m，4 sl
Hi,
I’m experiencing the same issue on Flink 18.1.
I have a slightly different job graph. I have a single Kafka Source
(parallelism 6) that is consuming from 2 topics, one topic with 4 partitions
and one topic with 6 partitions.
The autoWatermarkInteval change to 0 didn’t fix my issue.
Did yo
Hello,
I have several versions of Flink (1.17.0, 1.18.0, 1.18.1 and 1.19.0) on my
server.
I am still trying it out (on & off), and I was running a job for sync a
table from mysql to elasticsearch and it was running find without any
problems ( I was using 1.18.1 version).
But after a few weeks, I f
