fix: pin arrow to 55.0.0

Signed-off-by: Ion Koutsouris <[email protected]>

Author: ion-elgreco

Cargo.toml

@@ -32,19 +32,19 @@ delta_kernel = { version = "0.10.0", features = [
 ] }
 
 # arrow
-arrow = { version = "55" }
-arrow-arith = { version = "55" }
-arrow-array = { version = "55", features = ["chrono-tz"] }
-arrow-buffer = { version = "55" }
-arrow-cast = { version = "55" }
-arrow-ipc = { version = "55" }
-arrow-json = { version = "55" }
-arrow-ord = { version = "55" }
-arrow-row = { version = "55" }
-arrow-schema = { version = "55" }
-arrow-select = { version = "55" }
+arrow = { version = "=55.0.0" }
+arrow-arith = { version = "=55.0.0" }
+arrow-array = { version = "=55.0.0", features = ["chrono-tz"] }
+arrow-buffer = { version = "=55.0.0" }
+arrow-cast = { version = "=55.0.0" }
+arrow-ipc = { version = "=55.0.0" }
+arrow-json = { version = "=55.0.0" }
+arrow-ord = { version = "=55.0.0" }
+arrow-row = { version = "=55.0.0" }
+arrow-schema = { version = "=55.0.0" }
+arrow-select = { version = "=55.0.0" }
 object_store = { version = "0.12.1" }
-parquet = { version = "55" }
+parquet = { version = "=55.0.0" }
 
 # datafusion
 datafusion = "47.0.0"

crates/core/src/logstore/mod.rs

@@ -152,7 +152,8 @@ static DELTA_LOG_PATH: LazyLock<Path> = LazyLock::new(|| Path::from("_delta_log"
 /// # use std::collections::HashMap;
 /// # use url::Url;
 /// let location = Url::parse("memory:///").expect("Failed to make location");
-/// let logstore = logstore_for(location, HashMap::<String, String>::new(), None).expect("Failed to get a logstore");
+/// let storage_config = StorageConfig::default();
+/// let logstore = logstore_for(location, storage_config).expect("Failed to get a logstore");
 /// ```
 pub fn logstore_for(location: Url, storage_config: StorageConfig) -> DeltaResult<LogStoreRef> {
     // turn location into scheme

python/tests/pyspark_integration/utils.py

@@ -20,6 +20,7 @@ def get_spark():
     builder = (
         pyspark.sql.SparkSession.builder.appName("MyApp")
         .config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension")
+        .config("spark.driver.bindAddress", "127.0.0.1")
         .config(
             "spark.sql.catalog.spark_catalog",
             "org.apache.spark.sql.delta.catalog.DeltaCatalog",