我在一段无法抛出的代码中得到一个 NullPointerException。 我开始考虑在 JRE 中发现一个错误。我使用javac 1.8.0_51 作为编译器，问题出现在jre 1.8.0_45 和最新的1.8.0_60 中。

抛出异常的行在一个循环内，它在一个闭包 lambda 函数内。我们在 spark 1.4 中运行这样的关闭。 该行执行了 1 到 2 百万次，我得到的错误不是确定性的，使用相同的输入，每 3 或 4 次运行一次。

我在这里粘贴相关代码:

        JavaRDD .... mapValues(iterable -> {
                LocalDate[] dates = ...
                long[] dateDifferences = ...

                final double[] fooArray = new double[dates.length];
                final double[] barArray = new double[dates.length];
                for (Item item : iterable) {
                    final LocalDate myTime = item.getMyTime();
                    final int largerIndex = ...
                    if (largerIndex == 0) {
                        ...
                    } else if (largerIndex >= dates.length - 1) {
                        ...
                    } else {
                        final LocalDate largerDate = dates[largerIndex];
                        final long daysBetween = ...
                        if (daysBetween == 0) {
                            ...
                        } else {
                            double factor = ...
                            // * * * NULL POINTER IN NEXT LINE * * * //
                            fooArray[largerIndex - 1] += item.getFoo() * factor;
                            fooArray[largerIndex] += item.getFoo() * (1 - factor);
                            barArray[largerIndex - 1] += item.getBar() * factor;
                            barArray[largerIndex] += item.getBar() * (1 - factor);
                        }
                    }
                }
                return new NewItem(fooArray, barArray);
            })
            ...

我开始分析代码并发现:

• fooArray 永远不会为 null，因为上面有几行是“新的”
• largerIndex 是原始的
• item 永远不会为空，因为它已经在上面的几行中使用了
• getFoo() 不拆箱返回 double
• 因素是原始的

我无法在本地运行相同的输入并对其进行调试:这是在 spark 集群上运行的。所以我在 throw 行之前添加了一些调试 println:

System.out.println("largerIndex: " + largerIndex);
System.out.println("foo: " + Arrays.toString(foo));
System.out.println("foo[1]: " + foo[1]);
System.out.println("largerIndex-1: " + (largerIndex-1));
System.out.println("foo[largerIndex]: " + foo[largerIndex]);
System.out.println("foo[largerIndex - 1]: " + foo[largerIndex - 1]);

这是输出:

largerIndex: 2
foo: [0.0, 0.0, 0.0, 0.0, ...]
foo[1]: 0.0
largerIndex-1: 1
foo[largerIndex]: 0.0
15/10/01 12:36:11 WARN scheduler.TaskSetManager: Lost task 0.0 in stage 7.0 (TID 17162, host13): java.lang.NullPointerException
    at my.class.lambda$mymethod$87560622$1(MyFile.java:150)
    at my.other.class.$$Lambda$306/764841389.call(Unknown Source)
    at org.apache.spark.api.java.JavaPairRDD$$anonfun$toScalaFunction$1.apply(JavaPairRDD.scala:1027)
    ...

所以 foo[largerIndex - 1] 当前正在抛出空指针。请注意，以下也会抛出它:

int idx = largerIndex - 1;
foo[idx] += ...;

但不是以下内容:

foo[1] += ....;

我查看了类文件中的字节码，没有发现任何异常。在 iconst_1、isub 和 daload 之前，您在堆栈中正确地引用了 foo 和 largerIndex。

我发布这个只是为了在考虑 jre 错误之前收集想法。 你们中有人使用 spark 遇到过同类问题吗？或一般的 lambda 函数。是否可以使用一些调试标志运行 jvm 来帮助我理解这种奇怪的行为？或者我应该将问题提交给某个地方的人吗？

最佳答案

在我看来，这与此处描述的问题(JIT 问题)非常相似: http://kingsfleet.blogspot.com.br/2014/11/but-thats-impossible-or-finding-out.html

您观察到它不会每次都发生，并且在阅读代码时“不可能”发生，这与此处描述的完全相同。 要找到它，请使用命令行选项将您的方法排除在 JIT 之外(您需要指定正确的类/方法名称):

-XX:CompileCommand=exclude,java/lang/String.indexOf

或者通过完全关闭它来使用

-Xint

这可能太激烈了。

关于java - 在不能抛出的地方抛出 NullPointerException，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32904906/