apache/flink · error · EOFException

Could not skip .

Error message

Could not skip {}.

What it means

Thrown as EOFException by Record's internal skipBytesToRead when fewer than the requested number of bytes remain between the current position and the end of the record's binary segment. Unlike skipBytes (which skips partially), this guard requires the full count to be skippable.

Solutions

1. Address the cause reported by the error message: Could not skip 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 ("Could not skip the reported value.") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Could not skip the reported value.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Could not skip the reported value.

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

Appendix: source

Thrown at flink-core/src/main/java/org/apache/flink/types/Record.java:1567

            }
        }

        @Override
        public int skipBytes(int n) throws IOException {
            if (this.position <= this.end - n) {
                this.position += n;
                return n;
            } else {
                n = this.end - this.position;
                this.position = this.end;
                return n;
            }
        }

        @Override
        public void skipBytesToRead(int numBytes) throws IOException {
            if (this.end - this.position < numBytes) {
                throw new EOFException("Could not skip " + numBytes + ".");
            }
            skipBytes(numBytes);
        }

        @Override
        public int read(byte[] b, int off, int len) throws IOException {
            if (b == null) {
                throw new NullPointerException("Byte array b cannot be null.");
            }

            if (off < 0) {
                throw new IndexOutOfBoundsException("Offset cannot be negative.");
            }

            if (len < 0) {
                throw new IndexOutOfBoundsException("Length cannot be negative.");
            }

View on GitHub (pinned to 2f3c205e92)