Hi rania, Does "pending records" specifically refer to the records that have been read from the source but have not been processed yet?
If this is the case, FLIP-33[1] introduces some standard metrics for Source, including "pendingRecords," which can be helpful. However, not all Sources support this metric. For specific information, please refer to the documentation of the specific Source. Best, Jiabao [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-33%3A+Standardize+Connector+Metrics On 2023/11/26 16:09:54 rania duni wrote: > Hello! > I want to get the pending records of a task. What is the best approach to get > the unprocessed records of a task?
