你需要一个 FlatMapFunction 而不是 MapFunction . 这将允许您仅发射有效的元素。下面显示了一个示例实现：

input.flatMap(new FlatMapFunction<String, Long>() {
    @Override
    public void flatMap(String input, Collector<Long> collector) throws Exception {
        try {
            Long value = Long.parseLong(input);
            collector.collect(value);
        } catch (NumberFormatException e) {
            // ignore invalid data
        }
    }
});

这是建立在@till rohrmann上面的想法之上的。将此添加为答案而不是注解以获得更好的格式。
我认为实现“split+select”的一种方法是使用带有sideoutput的processfunction。我的图表如下所示：

Source --> ValidateProcessFunction ---good data--> UDF--->SinkToOutput
                                    \
                                     \---bad data----->SinkToErrorChannel

这样行吗？有更好的办法吗？