fix parquect schema check

Author: ZENOTME

crates/e2e_test/Cargo.toml

@@ -34,4 +34,4 @@ iceberg_test_utils = { path = "../test_utils", features = ["tests"] }
 log = { workspace = true }
 parquet = { workspace = true }
 port_scanner = { workspace = true }
-tokio = { version = "1", features = ["full"] }
+tokio = { workspace = true }

crates/e2e_test/tests/append_data_file_test.rs

@@ -32,7 +32,7 @@ use iceberg::{Catalog, Namespace, NamespaceIdent, TableCreation};
 use iceberg_catalog_rest::{RestCatalog, RestCatalogConfig};
 use iceberg_test_utils::docker::DockerCompose;
 use iceberg_test_utils::{normalize_test_name, set_up};
-use parquet::arrow::ParquetRecordBatchStreamBuilder;
+use parquet::arrow::arrow_reader::ArrowReaderOptions;
 use parquet::file::properties::WriterProperties;
 use port_scanner::scan_port_addr;
 use std::collections::HashMap;
@@ -171,18 +171,19 @@ async fn test_append_data_file() {
     let data_file = data_file_writer.close().await.unwrap();
 
     // check parquet file schema
-    let batch_stream_builder = ParquetRecordBatchStreamBuilder::new(
-        table
-            .file_io()
-            .new_input(data_file[0].file_path())
-            .unwrap()
-            .reader()
-            .await
-            .unwrap(),
+    let content = table
+        .file_io()
+        .new_input(data_file[0].file_path())
+        .unwrap()
+        .read()
+        .await
+        .unwrap();
+    let parquet_reader = parquet::arrow::arrow_reader::ArrowReaderMetadata::load(
+        &content,
+        ArrowReaderOptions::default(),
     )
-    .await
     .unwrap();
-    let field_ids: Vec<i32> = batch_stream_builder
+    let field_ids: Vec<i32> = parquet_reader
         .parquet_schema()
         .columns()
         .iter()