实时计算 Flink版产品使用合集之流处理过程中，对于某一条数据的异常，该如何处理

<dependency>
    <groupId>com.github.java-faker</groupId>
    <artifactId>java-faker</artifactId>
    <version>1.0.2</version>
</dependency>

import com.github.javafaker.Faker;
import com.github.javafaker.field.ArrayField;
import com.github.javafaker.provider.internet.Internet;
public class FlinkFakerDemo {
    public static void main(String[] args) {
        Faker faker = new Faker();
        ArrayField<String> arrayField = new ArrayField<>(String.class, Internet.URL);
        String[] urls = arrayField.generate(faker);
        for (String url : urls) {
            System.out.println(url);
        }
    }
}

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.util.Collector;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.concurrent.TimeUnit;
public class FlinkSubtract24Hours {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<String> input = env.fromElements("2022-01-01 12:00:00");
        DataStream<String> output = input.map(new MapFunction<String, String>() {
            @Override
            public String map(String value) throws Exception {
                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                LocalDateTime dateTime = LocalDateTime.parse(value, formatter);
                LocalDateTime newDateTime = dateTime.minus(1, TimeUnit.HOURS);
                return newDateTime.format(formatter);
            }
        });
        output.print();
        env.execute("Flink Subtract 24 Hours");
    }
}