apache/flink · error · NullPointerException

Operator producing the next partial solution must not be nul

Error message

Operator producing the next partial solution must not be null.

What it means

Thrown by BulkIterationBase.setNextPartialSolution(Operator<T> result) with a NullPointerException when the result argument is null. The 'next partial solution' is the operator that produces the updated solution for each iteration step — it is the core of the iteration body and cannot be absent.

Source

Thrown at flink-core/src/main/java/org/apache/flink/api/common/operators/base/BulkIterationBase.java:102

                name);
        inputPlaceHolder = new PartialSolutionPlaceHolder<T>(this, this.getOperatorInfo());
    }

    // --------------------------------------------------------------------------------------------

    /**
     * @return The operator representing the partial solution.
     */
    public Operator<T> getPartialSolution() {
        return this.inputPlaceHolder;
    }

    /**
     * @param result
     */
    public void setNextPartialSolution(Operator<T> result) {
        if (result == null) {
            throw new NullPointerException(
                    "Operator producing the next partial solution must not be null.");
        }
        this.iterationResult = result;
    }

    /**
     * @return The operator representing the next partial solution.
     */
    public Operator<T> getNextPartialSolution() {
        return this.iterationResult;
    }

    /**
     * @return The operator representing the termination criterion.
     */
    public Operator<?> getTerminationCriterion() {
        return this.terminationCriterion;
    }

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Ensure the step function operator (the body of the iteration that produces the next partial solution) is always non-null before calling setNextPartialSolution().
2. Initialize the step function variable before the call, or assert it is not null.
3. Use the DeltaIteration API if you need a different iteration model.

Example fix

// before
Operator<MyType> stepFunction = buildStepFunction(iteration.getPartialSolution());
// buildStepFunction may return null
iteration.setNextPartialSolution(stepFunction); // NPE if null

// after
Operator<MyType> stepFunction = buildStepFunction(iteration.getPartialSolution());
java.util.Objects.requireNonNull(stepFunction, "step function must not be null");
iteration.setNextPartialSolution(stepFunction);

void safeSetNextPartialSolution(BulkIterationBase<T> iter, Operator<T> result) {
    java.util.Objects.requireNonNull(result, "Step function operator must not be null");
    iter.setNextPartialSolution(result);
}

boolean isValidStepFunction(Operator<?> result) {
    return result != null;
}

try {
    iteration.setNextPartialSolution(stepFunction);
} catch (NullPointerException e) {
    throw new IllegalStateException("Iteration step function was null", e);
}

When it happens

Trigger: Calling iteration.setNextPartialSolution(null) directly. Passing a variable that was not initialized or was conditionally set to null as the step function result.

Common situations: Building a bulk iteration programmatically (legacy DataSet API) where the step function is computed from conditional logic that may return null. Refactoring code where the step function operator was removed but the call site was not updated.

Related errors

• The number of iterations must be at least one.
• Operator for initial partial solution is not set.
• Operator producing the next version of the partial solution
• No termination condition is set (neither fix number of itera
• The BulkIteration meta operator cannot have broadcast inputs

AI-assisted analysis of apache/flink@2f3c205e92 (2026-08-14). Data as JSON: /api/errors/9fd1fa3e49d9ee8c. Report an issue: GitHub.