You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@arrow.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/05/04 23:48:00 UTC

[jira] [Updated] (ARROW-16473) [Go] Memory leak in parquet page reading

     [ https://issues.apache.org/jira/browse/ARROW-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated ARROW-16473:
-----------------------------------
    Labels: pull-request-available  (was: )

> [Go] Memory leak in parquet page reading
> ----------------------------------------
>
>                 Key: ARROW-16473
>                 URL: https://issues.apache.org/jira/browse/ARROW-16473
>             Project: Apache Arrow
>          Issue Type: Bug
>          Components: Go, Parquet
>            Reporter: Min-Young Wu
>            Assignee: Min-Young Wu
>            Priority: Minor
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> {code:go}
> package main_test
> import (
> 	"context"
> 	"os"
> 	"testing"
> 	"github.com/apache/arrow/go/v8/arrow/memory"
> 	"github.com/apache/arrow/go/v8/parquet"
> 	"github.com/apache/arrow/go/v8/parquet/file"
> 	"github.com/apache/arrow/go/v8/parquet/pqarrow"
> )
> func TestParquetReading(t *testing.T) {
> 	ctx := context.Background()
> 	mem := memory.NewCheckedAllocator(memory.DefaultAllocator)
> 	defer mem.AssertSize(t, 0)
> 	f, err := os.Open("test.parquet")
> 	if err != nil {
> 		t.Fatal(err)
> 	}
> 	defer f.Close()
> 	pf, err := file.NewParquetReader(
> 		f,
> 		// Note: use the provided memory allocator
> 		file.WithReadProps(parquet.NewReaderProperties(mem)),
> 	)
> 	if err != nil {
> 		t.Fatal(err)
> 	}
> 	defer pf.Close()
> 	r, err := pqarrow.NewFileReader(pf, pqarrow.ArrowReadProperties{}, mem)
> 	if err != nil {
> 		t.Fatal(err)
> 	}
> 	table, err := r.ReadTable(ctx)
> 	if err != nil {
> 		t.Fatal(err)
> 	}
> 	defer table.Release()
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)