Re: Question about MapState size

2022-01-23 Thread Yun Tang
January 22, 2022 14:51 To: user@flink.apache.org Subject: Question about MapState size Hello, I have a streaming application that has an operator based on the KeyedCoProcessFunction. The operator has a MapState object. I store some data in this operator with a fixed ttl. I would like to monitor the

Question about MapState size

2022-01-21 Thread Abdul Rahman
Hello, I have a streaming application that has an operator based on the KeyedCoProcessFunction. The operator has a MapState object. I store some data in this operator with a fixed ttl. I would like to monitor the size/count of this state over time since its related to some operational metrics we