目前，我正在为一些分布式处理工具构建一个基准测试工具，在使用apache flink时遇到了一些问题。
设置很简单：logpojo是一个简单的pojo，有三个字段（长日期、双值、字符串数据）。在一个列表中，我正在寻找一个具有最小“value”字段的logpojo。基本相当于：

pojoList.stream().min(new LogPojo.Comp()).get().getValue();

我的flink设置如下所示：

public double processLogs(List<LogPojo> logs) {
    final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
    DataSet<LogPojo> logSet = env.fromCollection(logs);
    double result = 0.0;
    try {
        ReduceOperator ro = logSet.reduce(new LogReducer());
        List<LogPojo> c = ro.collect();
        result = c.get(0).getValue();
    } catch (Exception ex) {
        System.out.println("Exception caught" + ex);
    }
    return result;
}
public class LogReducer implements ReduceFunction<LogPojo> {
    @Override
    public LogPojo reduce(LogPojo o1, LogPojo o2) {
        return (o1.getValue() < o2.getValue()) ? o1 : o2;
    }
}

它停止于：

Exception in thread "main" java.lang.NoSuchMethodError: scala.collection.immutable.HashSet$.empty()Lscala/collection/immutable/HashSet;

所以它似乎无法应用reduce函数。我就是找不到，为什么。有什么提示吗？