Skip to content

Conversation

@xx789633
Copy link
Contributor

@xx789633 xx789633 commented Oct 30, 2025

Purpose

Linked issue: close #xxx

reference:
https://arrow.apache.org/docs/java/memory.html#why-arrow-uses-direct-memory

Brief change log

Tests

API and Format

Documentation


> **NOTE**: Fluss v0.8 only supports tiering log tables to Lance.
> **NOTE**: The Lance connector leverages Arrow Java library, which operates on off-heap memory. To prevent `java.lang.OutOfMemoryError: Direct buffer memory` error in Flink Task Manager, please increase the value of `taskmanager.memory.task.off-heap.size` in `<FLINK_HOME>/conf/config.yaml` to an appropriate size.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

what's the appropriate size? Any suggestion?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I have updated this to a more concrete suggestion.


> **NOTE**: Fluss v0.8 only supports tiering log tables to Lance.
> **NOTE**: The Lance connector leverages Arrow Java library, which operates on off-heap memory. To prevent `java.lang.OutOfMemoryError: Direct buffer memory` error in Flink Task Manager, please increase the value of `taskmanager.memory.task.off-heap.size` in `<FLINK_HOME>/conf/config.yaml` to an appropriate size.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

what's the appropriate size? Any suggestion?

@luoyuxia luoyuxia requested a review from Copilot October 31, 2025 01:09
Copy link

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull Request Overview

This PR adds a documentation note about configuring off-heap memory for the Lance connector to prevent OutOfMemoryError issues in Flink Task Manager.

  • Adds a new NOTE section explaining the Arrow Java library's off-heap memory requirements
  • Provides guidance on configuring taskmanager.memory.task.off-heap.size to avoid memory errors

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

Copy link
Contributor

@luoyuxia luoyuxia left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1

@luoyuxia luoyuxia merged commit 613d354 into apache:main Oct 31, 2025
2 checks passed
wuchong pushed a commit that referenced this pull request Nov 2, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants