-
Notifications
You must be signed in to change notification settings - Fork 117
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
Upgraded gosnowflake as v1.8.0 has an issue with arrow batches #4408
Conversation
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.
Looking at this, it seems like there's an error scenario where the writeGrp
fails early (e.g. because of missing file permissions or a storage limit error), but the fetchGrp
keeps downloading for a long time.
Similarly, this PR removes the ctx
check in the writeGrp
goroutine, which might lead to a lot of redundant writing if the fetchGrp
fails.
I think this can be solved by using a single errgroup
to coordinate all the goroutines (and having a if ctx.Err() != nil
check inside the for-loop of the writing goroutine).
* Reverted gosnowflake as v1.8.0 has an issue with arrow batches * Upgraded to a specific gosnowflake commit that fixes the issue * Fixed an issue causing writeGrp to stop early with "context cancelled" * Described the reason behind the version upgrade * Simplified by moving fetch and write into a single goroutine
snowflakedb/gosnowflake#1068