diff --git a/Cargo.toml b/Cargo.toml index e57fb42e8fb..d1c8b29e647 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -68,8 +68,7 @@ futures = { version = "0.3", optional = true } ahash = { version = "0.7", optional = true } # parquet support -#parquet2 = { version = "0.9", optional = true, default_features = false, features = ["stream"] } -parquet2 = { git = "https://github.com/jorgecarleitao/parquet2", branch = "writer", optional = true, default_features = false, features = ["stream"] } +parquet2 = { version = "0.10", optional = true, default_features = false, features = ["stream"] } # avro support avro-schema = { version = "0.2", optional = true } diff --git a/tests/it/io/parquet/mod.rs b/tests/it/io/parquet/mod.rs index db586bb0865..49e58e6d495 100644 --- a/tests/it/io/parquet/mod.rs +++ b/tests/it/io/parquet/mod.rs @@ -645,6 +645,7 @@ fn integration_write(schema: &Schema, batches: &[Chunk>]) -> Resu let mut writer = FileWriter::try_new(writer, schema.clone(), options)?; + writer.start()?; for group in row_groups { let (group, len) = group?; writer.write(group, len)?; diff --git a/tests/it/io/parquet/write.rs b/tests/it/io/parquet/write.rs index e671aa43af9..98d50841634 100644 --- a/tests/it/io/parquet/write.rs +++ b/tests/it/io/parquet/write.rs @@ -47,6 +47,7 @@ fn round_trip( let writer = Cursor::new(vec![]); let mut writer = FileWriter::try_new(writer, schema, options)?; + writer.start()?; for group in row_groups { let (group, len) = group?; writer.write(group, len)?;