Hacktoberfest 2026: những issue maintainer đã đánh dấu cho tháng Mười, đang mở và phù hợp người mới. Xem issue Hacktoberfest

[client] LimitBatchScanner leaks Arrow read context on log-table LIMIT scan

Đang mở Phù hợp với người mới
  • Có gì không ổn?
#4,353 0 bình luận 0 reaction 0 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 1 ngày

@EchoLee5 đang làm issue này rồi.

Từ ngày 16/9/2026.

  • #4356 của @EchoLee5 — đang mở

Đánh giá

Độ khó
2/5
Thời gian dự kiến
1-3 giờ
Mức phù hợp với người mới
78/100
Loại issue
Lỗi
Độ rõ ràng
Đặc tả rõ ràng
Mức độ hoạt động
Sôi nổi
Công nghệ
java
Lĩnh vực
database

Hướng nghiên cứu

Bắt đầu trong phần triển khai LimitBatchScanner của fluss-client tại parseLimitScanResponse(), tập trung vào nhánh bảng log gọi LogRecordReadContext.createReadContext(). Đảm bảo read context được đóng sau khi phân tích cú pháp và khi việc phân tích cú pháp thất bại; hoàn tất nghĩa là các lần quét LIMIT giải phóng Arrow allocator trước khi scanner đóng.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

Description

LimitBatchScanner.parseLimitScanResponse() creates a LogRecordReadContext for log tables (no primary key) and never closes it.

For Arrow log format, LogRecordReadContext.createReadContext() allocates a RootAllocator backed by the scanner's ChunkedFactory. The record iterator is closed, and rows are deep-copied, but the read context itself is left open. LimitBatchScanner.close() only closes chunkedFactory, so the allocator and its off-heap chunks can leak on every LIMIT scan of an Arrow log table.

LogRecordReadContext readContext =
        LogRecordReadContext.createReadContext(...);
// iterated, then dropped without readContext.close()

This is a different path from #4345 (LogFetcher / LogScannerImpl close chain).

Expected

LogRecordReadContext is closed after parsing (including on parse failure), so Arrow allocators are released before the scanner is closed.

How to reproduce

  1. Create an Arrow log table (no primary key).
  2. Run a LIMIT scan / LimitBatchScanner.pollBatch().
  3. Close the scanner. The read-context allocator is never closed.

Component

fluss-client — LimitBatchScanner

Ngôn ngữ chính
Java
Star
2.2k
Fork
656
Merge trung bình
2 ngày 2 giờ
Pull request đã merge (30 ngày)
120

Chuẩn bị môi trường

  • Không có Dockerfile hay tệp Docker Compose
  • Có mẫu pull request
  • Không có hướng dẫn đóng góp

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của apache/fluss

Tất cả issue của apache/fluss

Issue tương tự

Thêm issue về Java

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.