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
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
流模式和批模式在watermark和一些算子语义等方面上有一些不同，但没看到Join和Window算子上有什么差异，这方面应该在batch
mode下应该是支持的。具体的两种模式的比较可以看一下这个文档
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/datastream/execution_mode/
On Thu, Apr 18, 2024 at 9:44 AM casel.chen wrote:
>
> 有人尝试这么实践过么？可以给一些建议么？谢谢！
>
>
>
>
>
>
>
>
>
>
>
>
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
