Skip to content

Commit

Permalink
fix check
Browse files Browse the repository at this point in the history
  • Loading branch information
ZENOTME committed Nov 27, 2024
1 parent 1b2e12b commit 6a1eab8
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 10 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@
resolver = "2"
members = [
"crates/catalog/*",
"crates/integration_tests",
"crates/examples",
"crates/iceberg",
"crates/integration_tests",
"crates/integrations/*",
"crates/test_utils",
]
Expand Down
14 changes: 7 additions & 7 deletions crates/iceberg/src/spec/table_metadata_builder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1818,7 +1818,7 @@ mod tests {
.with_manifest_list("/snap-1.avro")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::from_iter(vec![
additional_properties: HashMap::from_iter(vec![
(
"spark.app.id".to_string(),
"local-1662532784305".to_string(),
Expand Down Expand Up @@ -1881,7 +1881,7 @@ mod tests {
.with_manifest_list("/snap-1.avro")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::from_iter(vec![
additional_properties: HashMap::from_iter(vec![
(
"spark.app.id".to_string(),
"local-1662532784305".to_string(),
Expand All @@ -1901,7 +1901,7 @@ mod tests {
.with_manifest_list("/snap-1.avro")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::from_iter(vec![
additional_properties: HashMap::from_iter(vec![
(
"spark.app.id".to_string(),
"local-1662532784305".to_string(),
Expand Down Expand Up @@ -1949,7 +1949,7 @@ mod tests {
.with_manifest_list("/snap-1.avro")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::new(),
additional_properties: HashMap::new(),
})
.build();

Expand Down Expand Up @@ -1994,7 +1994,7 @@ mod tests {
.with_manifest_list("/snap-1.avro")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::from_iter(vec![
additional_properties: HashMap::from_iter(vec![
(
"spark.app.id".to_string(),
"local-1662532784305".to_string(),
Expand Down Expand Up @@ -2114,7 +2114,7 @@ mod tests {
.with_manifest_list("/snap-1")
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::new(),
additional_properties: HashMap::new(),
})
.build();

Expand All @@ -2140,7 +2140,7 @@ mod tests {
.with_parent_snapshot_id(Some(1))
.with_summary(Summary {
operation: Operation::Append,
other: HashMap::new(),
additional_properties: HashMap::new(),
})
.build();

Expand Down
2 changes: 1 addition & 1 deletion crates/iceberg/src/transaction.rs
Original file line number Diff line number Diff line change
Expand Up @@ -327,7 +327,7 @@ impl<'a> SnapshotProduceAction<'a> {
.ok_or_else(|| {
Error::new(
ErrorKind::Unexpected,
"Partition field should only be primitve type.",
"Partition field should only be primitive type.",
)
})?
.compatible(&value.as_primitive_literal().unwrap())
Expand Down
3 changes: 2 additions & 1 deletion crates/integration_tests/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
// under the License.

use std::collections::HashMap;
use std::net::{IpAddr, Ipv4Addr};

use iceberg::io::{S3_ACCESS_KEY_ID, S3_ENDPOINT, S3_REGION, S3_SECRET_ACCESS_KEY};
use iceberg_catalog_rest::{RestCatalog, RestCatalogConfig};
Expand All @@ -41,7 +42,7 @@ pub async fn set_test_fixture(func: &str) -> TestFixture {
// Start docker compose
docker_compose.run();

let rest_catalog_ip = docker_compose.get_container_ip("rest");
let rest_catalog_ip = IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1));

let read_port = format!("{}:{}", rest_catalog_ip, REST_CATALOG_PORT);
loop {
Expand Down

0 comments on commit 6a1eab8

Please sign in to comment.