Recover S3 stream after skip failure

[electrum]

Release notes

(x) Release notes are required, with the following suggested text:

## Delta Lake connector
* Retry on S3 failure during forward seek operations. ({issue}`29419`)

## Hive connector
* Retry on S3 failure during forward seek operations. ({issue}`29419`)

## Hudi connector
* Retry on S3 failure during forward seek operations. ({issue}`29419`)

## Iceberg connector
* Retry on S3 failure during forward seek operations. ({issue}`29419`)

## Lakehouse connector
* Retry on S3 failure during forward seek operations. ({issue}`29419`)

[Copilot]

Pull request overview

This PR updates the S3 filesystem input stream behavior to be more resilient to transient S3 failures when performing forward seeks, which benefits lakehouse connectors that rely on forward seeking while reading object data.

Changes:

• Retry forward-seek operations by reopening the S3 stream when skip() fails with an IOException.
• Remove the previous zero-length response workaround tied to an AWS SDK issue.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[findepi]

Fix PR title

[electrum]

I addressed the Copilot comment to handle InterruptedIOException.

[electrum]

@coderabbitai full review

[coderabbitai]

✅ Actions performed

Full review triggered.

[coderabbitai]

No actionable comments were generated in the recent review. 🎉

ℹ️ Recent review info

⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Pro

Run ID: 4747aa84-c9ab-4b65-9a0d-fee1d2c0b552

📥 Commits

Reviewing files that changed from the base of the PR and between 73a7d29 and 396dc34.

📒 Files selected for processing (1)

• lib/trino-filesystem-s3/src/main/java/io/trino/filesystem/s3/S3InputStream.java

---

📝 Walkthrough

Walkthrough

This PR refactors S3InputStream's forward-seek behavior to inline skip logic with explicit exception handling. The previous doSkip helper method is removed, and its AbortedException-to-InterruptedIOException mapping is moved into the seek method. Additionally, an AWS SDK workaround that replaced zero-length streams with null-input streams during range request opening is removed. The net effect is clearer control flow for skip operations and reduced defensive coding for an edge case.

Tip

💬 Introducing Slack Agent: The best way for teams to turn conversations into code.

Slack Agent is built on CodeRabbit's deep understanding of your code, so your team can collaborate across the entire SDLC without losing context.

• Generate code and open pull requests
• Plan features and break down work
• Investigate incidents and troubleshoot customer tickets together
• Automate recurring tasks and respond to alerts with triggers
• Summarize progress and report instantly

Built for teams:

• Shared memory across your entire org—no repeating context
• Per-thread sandboxes to safely plan and execute work
• Governance built-in—scoped access, auditability, and budget controls

One agent for your entire SDLC. Right inside Slack.

👉 Get started

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

[Copilot]

Pull request overview

Copilot reviewed 1 out of 1 changed files in this pull request and generated 3 comments.