Using big state and want to do some performance tuning, how can i enable
RocksDB native metrics?
I am using Flink 1.14.4
Thanks,
Lei
Hi Mark,
IMHO, your design of the Flink application is generally feasible. In
Flink ML, I have once met a similar design in ChiSqTest operator,
where the input data is first aggregated to generate some results and
then broadcast and connected with other result streams from the same
input afterward
I am looking for some design advice for a new Flink application and I am
relatively new to Flink - I have one, fairly straightforward Flink
application in production so far.
For this new application, I want to create a three-stage processing
pipeline. Functionally, I am seeing this as ONE long dat