This is an automated email from the ASF dual-hosted git repository.

yangjie01 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new 71335da93af5 [SPARK-55248][SS] Clean up Jackson deprecated API usage 
in `streaming.checkpointing.Checksum`
71335da93af5 is described below

commit 71335da93af5baf0953a6b743cb11aacc3a4312b
Author: yangjie01 <[email protected]>
AuthorDate: Wed Jan 28 14:22:23 2026 +0800

    [SPARK-55248][SS] Clean up Jackson deprecated API usage in 
`streaming.checkpointing.Checksum`
    
    ### What changes were proposed in this pull request?
    This pr aims to clean up Jackson deprecated API usage in 
`streaming.checkpointing.Checksum`
    
    ### Why are the changes needed?
    clean up deprecated API usage
    
    ### Does this PR introduce _any_ user-facing change?
    No
    
    ### How was this patch tested?
    Pass Github Actions
    
    ### Was this patch authored or co-authored using generative AI tooling?
    No
    
    Closes #54024 from LuciferYang/SPARK-55248.
    
    Authored-by: yangjie01 <[email protected]>
    Signed-off-by: yangjie01 <[email protected]>
---
 .../streaming/checkpointing/ChecksumCheckpointFileManager.scala         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/ChecksumCheckpointFileManager.scala
 
b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/ChecksumCheckpointFileManager.scala
index 2de429ee1076..fcfad636ab77 100644
--- 
a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/ChecksumCheckpointFileManager.scala
+++ 
b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/ChecksumCheckpointFileManager.scala
@@ -79,7 +79,7 @@ object Checksum {
   /** Used to convert between class and JSON. */
   lazy val mapper = {
     val _mapper = new ObjectMapper with ClassTagExtensions
-    _mapper.setSerializationInclusion(Include.NON_ABSENT)
+    _mapper.setDefaultPropertyInclusion(Include.NON_ABSENT)
     _mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
     _mapper.registerModule(DefaultScalaModule)
     _mapper


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to