apache/flink · error · IllegalArgumentException

Checkpoint(%d) has not been snapshot. The watermark informat

Error message

Checkpoint(%d) has not been snapshot. The watermark information is: %s.

What it means

Error "Checkpoint(%d) has not been snapshot. The watermark information is: %s." thrown in apache/flink.

Source

Thrown at flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/PartitionTimeCommitTrigger.java:98

        this.watermarksState = stateStore.getListState(WATERMARKS_STATE_DESC);
        this.watermarks = new TreeMap<>();
        if (isRestored) {
            watermarks.putAll(watermarksState.get().iterator().next());
        }
    }

    @Override
    public void addPartition(String partition) {
        if (!StringUtils.isNullOrWhitespaceOnly(partition)) {
            this.pendingPartitions.add(partition);
        }
    }

    @Override
    public List<String> committablePartitions(long checkpointId) {
        if (!watermarks.containsKey(checkpointId)) {
            throw new IllegalArgumentException(
                    String.format(
                            "Checkpoint(%d) has not been snapshot. The watermark information is: %s.",
                            checkpointId, watermarks));
        }

        long watermark = watermarks.get(checkpointId);
        watermarks.headMap(checkpointId, true).clear();

        List<String> needCommit = new ArrayList<>();
        Iterator<String> iter = pendingPartitions.iterator();
        while (iter.hasNext()) {
            String partition = iter.next();
            PredicateContext predicateContext = createPredicateContext(partition, watermark);
            if (partitionCommitPredicate.isPartitionCommittable(predicateContext)) {
                needCommit.add(partition);
                iter.remove();
            }
        }

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Checkpoint(the reported value) has not been snapshot. The watermark information is: the reported value.
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Checkpoint(the reported value) has not been snapshot. The watermark information is: the reported value.") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Checkpoint(the reported value) has not been snapshot. The watermark information is: the reported value.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Checkpoint(the reported value) has not been snapshot. The watermark information is: the reported value.

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