Hi I am seeing the below logs in flink 1.13.0 running in YARN
2021-06-23T13:41:45.761Z WARN grid.task.MetricSdmStalenessUtils Legacy Source Thread - Source: MetricSource -> Filter -> MetricStoreMapper -> (Filter -> Timestamps/Watermarks -> Map -> Flat Map, Sink: FlinkKafkaProducer11, Sink: TSDBSink14) (1/1)#0 updateMetricStalenessInHisto:32 Received a non-positive staleness = -194239 at 1624455705761 Can someone let me know what does the "Legacy Source Thread" denotes? I saw the same question here <http://deprecated-apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/quot-Legacy-Source-Thread-quot-line-in-logs-td33941.html#a44594> in the deprecated mailing list with no answer. So starting a new email thread here.
