Alexey Seleznev
08/03/2023, 2:36 PMAlexey Seleznev
08/03/2023, 2:37 PMAlexey Seleznev
08/03/2023, 8:34 PMDEBUG org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction - Ignoring <s3://my-bucket/my-folder/my.json>, with mod time= 1691069277000 and global mod time= 9223372036854775807
it looks like during saving(restoring from?) a checkpoint, the globalModificationTime is saved(restored?) with Long.MAX_VAL 🤯 in
org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.javaAlexey Seleznev
08/03/2023, 9:02 PMDEBUG org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction - ContinuousFileMonitoringFunction retrieved a global mod time of 9223372036854775807.
That means this value is added during savepoint creation