Add requireNonNull check

sopel39 · Oct 29, 2018 · bd63cab · bd63cab
1 parent 7065180
commit bd63cab
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/presto-main/src/main/java/com/facebook/presto/operator/WorkProcessorUtils.java b/presto-main/src/main/java/com/facebook/presto/operator/WorkProcessorUtils.java
@@ -137,7 +137,7 @@ else if (processor.isBlocked()) {
                     }
 
                     if (processorIterator.hasNext()) {
-                        processor = processorIterator.next();
+                        processor = requireNonNull(processorIterator.next());
                         continue;
                     }
 
@@ -345,8 +345,7 @@ public T getResult()
 
     private static class ElementAndProcessor<T>
     {
-        @Nullable
-        final T element;
+        @Nullable final T element;
         final WorkProcessor<T> processor;
 
         ElementAndProcessor(T element, WorkProcessor<T> processor)