[SkipRecovery] Re-enable CORRECTED Parquet timestamp checks [databricks] - #15969
Open
wjxiz1992 wants to merge 1 commit into
Open
[SkipRecovery] Re-enable CORRECTED Parquet timestamp checks [databricks]#15969wjxiz1992 wants to merge 1 commit into
wjxiz1992 wants to merge 1 commit into
Conversation
Signed-off-by: Allen Xu <allxu@nvidia.com>
Contributor
|
Contributor
There was a problem hiding this comment.
🟢 Approval recommended
Changes are well validated; the remaining documentation nit is non-blocking.
Pull request overview
Re-enables existing CORRECTED Parquet timestamp parity checks and updates compatibility guidance without changing production behavior.
Changes:
- Removes expected-failure markers from timestamp round-trip tests.
- Documents supported CORRECTED timestamp behavior and limitations.
- Notes version-specific Parquet rebasing configuration keys.
File summaries
| File | Description |
|---|---|
integration_tests/src/main/python/parquet_test.py |
Restores normal failure reporting for timestamp round-trip cases. |
docs/compatibility.md |
Updates Parquet timestamp compatibility guidance. |
Review details
Suppressed comments (1)
docs/compatibility.md:319
- The write-rebase keys are version-dependent in this repository:
delta_lake_write_test.py:1089-1098uses thespark.sql.legacy.parquet.*keys before Spark 4.0 and thespark.sql.parquet.*keys from Spark 4.0 onward. As written, this compatibility statement can mislead users of the supported pre-4.0 Spark versions into setting keys that are not the version-appropriate controls; please document both forms or scope this claim to Spark 4.0+.
on Spark 3.0. For files written by the CPU on supported Spark versions with both
`spark.sql.parquet.datetimeRebaseModeInWrite` and `spark.sql.parquet.int96RebaseModeInWrite`
set to `CORRECTED`, GPU reads support timestamps before the transition between the Julian
- Files reviewed: 2/2 changed files
- Comments generated: 0
- Review effort level: Lite
💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.
Collaborator
Author
|
build |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
JaCoCo production line coverage: +0 lines (measured:
sql-plugin,delta-lake,iceberg,shuffle-plugin,udf-compiler; Scala 2.12, shim 350, vs compatible nightly b34, anchor2d438c020496)Contributes to #132.
Description
This is a test-and-documentation recovery; production behavior is unchanged. The existing CORRECTED Parquet timestamp round-trip cases produce matching CPU/GPU results on the tested runtime, but an old expected-failure marker still hides future failures. Remove that marker so these cases enforce parity, and correct the compatibility documentation's blanket warning about ancient CORRECTED timestamps.
CORRECTED.Validation used Apache Spark 3.5.0, Python 3.10.18, Java 17, and an RTX 5880 Ada. No CPU/GPU divergence was observed in the exercised scope. Databricks and other Spark shims have not been validated locally.
Local validation and coverage measurement
package -pl dist,integration_tests -am -Dbuildver=350 -DskipTests, with an isolated Maven cache: BUILD SUCCESS.--runxfail: 392 passed.TIMESTAMP_MICROSandTIMESTAMP_MILLIS: 196 passed per encoding. INT96 with a second seed and forced OOM injection: 196 passed.parquet_test.py: 3721 passed, 89 skipped in 1232.50 seconds, exit 0. The 89 skips are existing runtime guards, not expected failures restored by this change.Affected existing tests:
test_parquet_read_round_tripandtest_parquet_read_multithread_flow_ctrl_round_tripinintegration_tests/src/main/python/parquet_test.py. The recovered timestamp-only selection is-k '[Timestamp]'(52 ordinary-reader cases plus 144 flow-control cases). Runs used seed20260911, with20260912for the forced-OOM run; both CORRECTED write-rebase settings are set by the tests.JaCoCo replayed all 196 recovered cases against the exact compatible b34 anchor JAR and merged their execution data with that baseline. All five regenerated module baseline counters matched the published report, with no class-ID mismatch; each module's marginal line delta was zero. This measures restored regression enforcement, not new production lines. b34 is a compatible baseline, not the latest nightly.
AI assistance: The change and PR description were prepared with Codex assistance.
Checklists
Documentation
Testing
(Please provide the names of the existing tests in the PR description.)
Performance