-
Notifications
You must be signed in to change notification settings - Fork 173
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
test: Enable Spark 4.0 tests #537
test: Enable Spark 4.0 tests #537
Conversation
spark/src/main/spark-3.2/org/apache/comet/shims/CometExprShim.scala
Outdated
Show resolved
Hide resolved
spark/src/main/spark-3.3/org/apache/comet/shims/CometExprShim.scala
Outdated
Show resolved
Hide resolved
spark/src/main/spark-3.2/org/apache/comet/shims/CometExprShim.scala
Outdated
Show resolved
Hide resolved
spark/src/main/spark-3.3/org/apache/comet/shims/CometExprShim.scala
Outdated
Show resolved
Hide resolved
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #537 +/- ##
============================================
+ Coverage 54.68% 54.70% +0.01%
Complexity 795 795
============================================
Files 102 103 +1
Lines 9688 9707 +19
Branches 1845 1849 +4
============================================
+ Hits 5298 5310 +12
- Misses 3433 3444 +11
+ Partials 957 953 -4 ☔ View full report in Codecov by Sentry. |
spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala
Outdated
Show resolved
Hide resolved
@@ -88,7 +87,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim | |||
case _: BinaryType => 8 | |||
case _: TimestampType => 9 | |||
case _: DecimalType => 10 | |||
case dt if dt.typeName == "timestamp_ntz" => 11 | |||
case dt if isTimestampNTZType(dt) => 11 |
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.
Nice improvement
I didn't review the Spark diff, but the other changes LGTM from a first pass. I will review more carefully tomorrow. |
@andygrove just checking in to see if you have more feedback |
Friendly ping @andygrove @comphead @huaxingao @parthchandra @viirya |
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.
LGTM. Thanks @kazuyukitanimura
Waiting for #581 gets merged first |
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.
lgtm, thanks @kazuyukitanimura 👍
java-version: [11] | ||
spark-version: [{short: '3.4', full: '3.4.2'}] | ||
java-version: [17] | ||
spark-version: [{short: '4.0', full: '4.0.0-preview1'}] |
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 particular for ansi test? Hmm, is there any difference between 3.4 and 4.0?
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.
This has been disabled. List of failing tests #551
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.
Hmm, before we can enable it, can we still use 3.4 to run these tests?
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.
I have not tried running this with 3.4, but based on the comment, it likely fails.
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.
Ah, I forgot we don't run ansi test in CI.
Merged thank you @andygrove @comphead @viirya |
## Rationale for this change To be ready for Spark 4.0 ## What changes are included in this PR? This PR enables the spark-4.0 tests with comet enabled except for the ones listed in apache#551 ## How are these changes tested? ANSI is enabled for Spark-4.0
Which issue does this PR close?
Part of #372
Rationale for this change
To be ready for Spark 4.0
What changes are included in this PR?
This PR enables the spark-4.0 tests with comet enabled except for the ones listed in #551
How are these changes tested?
ANSI is enabled for Spark-4.0