-
-
Save MadhavJivrajani/fa69278be76cdf18143dcde533f0e193 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
================== | |
WARNING: DATA RACE | |
Write at 0x00c00054e090 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:325 +0x19d | |
github.com/segmentio/parquet-go.(*Reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:242 +0xb0 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:743 +0x1044 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c00054e097 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0000381b0 by goroutine 34: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0000381b7 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 34 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Read at 0x00c000a6bd14 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous write at 0x00c000a6bd10 by goroutine 40: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:890 +0x26d | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 40 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0000dc120 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:917 +0x4d7 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c0000dc127 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c004e3b3d0 by goroutine 38: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c004e3b3d7 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 38 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0007400c0 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:890 +0x26d | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c0007400c7 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c000038390 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:906 +0x475 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c000038397 by goroutine 38: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 38 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c006b8f940 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:325 +0x19d | |
github.com/segmentio/parquet-go.(*Reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:242 +0xb0 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:743 +0x1044 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c006b8f947 by goroutine 34: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 34 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0007236e0 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:917 +0x4d7 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0007236e7 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Read at 0x00c005d68158 by goroutine 38: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous write at 0x00c005d68158 by goroutine 40: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:890 +0x26d | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 38 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 40 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c00054e120 by goroutine 34: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:325 +0x19d | |
github.com/segmentio/parquet-go.(*Reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:242 +0xb0 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:743 +0x1044 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c00054e127 by goroutine 55: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 34 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 55 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Read at 0x00c004280054 by goroutine 73: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:588 +0x7f7 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous write at 0x00c004280050 by goroutine 36: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 73 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 36 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0004d40c0 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0004d40c7 by goroutine 73: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 73 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Read at 0x00c000118398 by goroutine 36: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous write at 0x00c000118398 by goroutine 35: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:906 +0x475 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 36 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 35 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c000118450 by goroutine 37: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c000118457 by goroutine 34: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 37 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 34 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c000722320 by goroutine 36: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:917 +0x4d7 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c000722327 by goroutine 73: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 36 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 73 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0004d41b0 by goroutine 41: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0004d41b7 by goroutine 73: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 41 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 73 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c00032a0c0 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c00032a0c7 by goroutine 54: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 54 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c00086d610 by goroutine 38: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c00086d617 by goroutine 54: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:231 +0x6ef | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 38 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 54 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c006b8f760 by goroutine 37: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:906 +0x475 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c006b8f767 by goroutine 54: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 37 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 54 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c000734330 by goroutine 84: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/polarsignals/arcticdb/dynparquet.(*remappedPages).ReadPage() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:703 +0x4d | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*bufferedRowGroupCursor).readNext() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:236 +0x75 | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).init() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:73 +0x31a | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:98 +0x7c | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:546 +0x451 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c000734337 by goroutine 68: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:231 +0x6ef | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 84 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 68 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c017ff3ab0 by goroutine 84: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/polarsignals/arcticdb/dynparquet.(*remappedPages).ReadPage() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:703 +0x4d | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*bufferedRowGroupCursor).readNext() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:236 +0x75 | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).init() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:73 +0x31a | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:98 +0x7c | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:546 +0x451 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c017ff3ab7 by goroutine 68: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 84 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 68 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c000665210 by goroutine 84: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/polarsignals/arcticdb/dynparquet.(*remappedPages).ReadPage() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:703 +0x4d | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*bufferedRowGroupCursor).readNext() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:236 +0x75 | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).init() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:73 +0x31a | |
github.com/segmentio/parquet-go.(*mergedRowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/merge.go:98 +0x7c | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:546 +0x451 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c000665217 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:136 +0x68b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 84 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c026a1cca0 by goroutine 81: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:906 +0x475 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c026a1cca7 by goroutine 87: | |
[failed to restore the stack] | |
Goroutine 81 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 87 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c01cc7a3c0 by goroutine 87: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:72 +0x883 | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c01cc7a3c7 by goroutine 81: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:900 +0x2fa | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 87 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 81 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c01cc7a3c8 by goroutine 87: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:72 +0x883 | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c01cc7a3c8 by goroutine 81: | |
[failed to restore the stack] | |
Goroutine 87 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 81 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c020b960f0 by goroutine 81: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.addPartToGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:890 +0x26d | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:632 +0x64 | |
github.com/polarsignals/arcticdb.(*PartList).Iterate() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/part_list.go:89 +0xc1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:631 +0xef5 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous read at 0x00c020b960f7 by goroutine 87: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:203 +0xcc6 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 81 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 87 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c01cc7a870 by goroutine 33: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*Granule).AddPart() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:106 +0x339 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:471 +0x527 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c01cc7a877 by goroutine 87: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:231 +0x6ef | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 33 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 87 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c002be68d0 by goroutine 35: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:325 +0x19d | |
github.com/segmentio/parquet-go.(*Reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:242 +0xb0 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:743 +0x1044 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c002be68d7 by goroutine 99: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:588 +0x7f7 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 35 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 99 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Read at 0x00c0068240c4 by goroutine 99: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*Granule).split() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:231 +0x6ef | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:595 +0x93a | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Previous write at 0x00c0068240c0 by goroutine 96: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/segmentio/parquet-go.(*reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:325 +0x19d | |
github.com/segmentio/parquet-go.(*Reader).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/reader.go:242 +0xb0 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:743 +0x1044 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 99 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Goroutine 96 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0000d73b0 by goroutine 18: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0000d73b7 by goroutine 93: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.copyBytes() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:743 +0x3ac | |
github.com/segmentio/parquet-go.Value.Clone() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/value.go:575 +0x31a | |
github.com/polarsignals/arcticdb/dynparquet.(*DynamicRows).GetCopy() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/row.go:24 +0x2c4 | |
github.com/polarsignals/arcticdb.NewGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/granule.go:82 +0x8cb | |
github.com/polarsignals/arcticdb.(*TableBlock).splitGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:588 +0x7f7 | |
github.com/polarsignals/arcticdb.(*TableBlock).compact() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:883 +0x95 | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert.func3() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x47 | |
Goroutine 18 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 93 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
================== | |
WARNING: DATA RACE | |
Write at 0x00c0000d73b8 by goroutine 18: | |
runtime.slicecopy() | |
/usr/local/go/src/runtime/slice.go:295 +0x0 | |
github.com/segmentio/parquet-go.(*Column).decodeDictionary() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column.go:695 +0x687 | |
github.com/segmentio/parquet-go.(*filePages).ReadPage() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/file.go:540 +0x90f | |
github.com/segmentio/parquet-go.(*columnChunkReader).readValues() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:81 +0xea | |
github.com/segmentio/parquet-go.readRowsFuncOfLeaf.func1() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:336 +0x386 | |
github.com/segmentio/parquet-go.readRowsFuncOfGroup.func2() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/column_chunk.go:307 +0x202 | |
github.com/segmentio/parquet-go.(*rowGroupRows).ReadRows() | |
/home/madhav/gocode/pkg/mod/github.com/segmentio/parquet-go@v0.0.0-20220524213358-0733add4c2cb/row_group.go:336 +0x279 | |
github.com/polarsignals/arcticdb/dynparquet.(*dynamicRowGroupReader).ReadRows() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/dynparquet/schema.go:242 +0x1c1 | |
github.com/polarsignals/arcticdb.(*TableBlock).splitRowsByGranule() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:780 +0x44b | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:458 +0x164 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
Previous read at 0x00c0000d73b8 by goroutine 93: | |
[failed to restore the stack] | |
Goroutine 18 (running) created at: | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:493 +0x1ef | |
testing.tRunner() | |
/usr/local/go/src/testing/testing.go:1439 +0x213 | |
testing.(*T).Run.func1() | |
/usr/local/go/src/testing/testing.go:1486 +0x47 | |
Goroutine 93 (running) created at: | |
github.com/polarsignals/arcticdb.(*TableBlock).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:478 +0x745 | |
github.com/polarsignals/arcticdb.(*Table).Insert() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:255 +0x1fd | |
github.com/polarsignals/arcticdb.(*Table).InsertBuffer() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table.go:242 +0x144 | |
github.com/polarsignals/arcticdb.Test_Table_Concurrency.func1.2() | |
/home/madhav/gocode/src/github.com/MadhavJivrajani/arcticdb/table_test.go:496 +0x144 | |
================== | |
--- FAIL: Test_Table_Concurrency (31.35s) | |
--- FAIL: Test_Table_Concurrency/1024 (9.57s) | |
table_test.go:33: level=debug msg="read blocks" n=0 | |
testing.go:1312: race detected during execution of test | |
--- FAIL: Test_Table_Concurrency/4096 (6.62s) | |
table_test.go:33: level=debug msg="read blocks" n=0 | |
testing.go:1312: race detected during execution of test | |
--- FAIL: Test_Table_Concurrency/2048 (8.78s) | |
table_test.go:33: level=debug msg="read blocks" n=0 | |
testing.go:1312: race detected during execution of test | |
testing.go:1312: race detected during execution of test | |
FAIL | |
exit status 1 | |
FAIL github.com/polarsignals/arcticdb 31.388s |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment