-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Update arrow 49.0.0 and object_store 0.8.0 #8029
Conversation
datafusion/core/tests/fifo.rs
Outdated
@@ -336,6 +336,7 @@ mod unix_test { | |||
|
|||
/// It tests the INSERT INTO functionality. | |||
#[tokio::test] | |||
#[ignore] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
#8021 shows how these tests might be ported
e60aa4d
to
d0875ce
Compare
I believe this upgrade is blocked on sorting out how to upgrade the design to handle FIFO files as described in #8021 |
Technically speaking this bug was fixed by the update to 48.0.1 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you @tustvold -- I know this was a long time in the making but the result is great.
I think this upgrade makes the code look much nicer (removing the double layer of errors from the object store APIs is quite nice 👨🍳 👌 )
.await? | ||
.try_collect() | ||
.await?; | ||
let entries: Vec<_> = self.store.list(Some(&self.path)).try_collect().await?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
that is certainly nicer
@@ -680,7 +680,11 @@ mod tests { | |||
// Ensure a useful error happens at plan time if invalid casts are used | |||
let schema = Schema::new(vec![Field::new("a", DataType::Int32, false)]); | |||
|
|||
let result = cast(col("a", &schema).unwrap(), &schema, DataType::LargeBinary); | |||
let result = cast( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this change needed because arrow now supports casting Int32 --> LargeBinary?
Which issue does this PR close?
Closes #8092
Rationale for this change
What changes are included in this PR?
Are these changes tested?
Are there any user-facing changes?