HeartSaVioR opened a new pull request, #49984:
URL: https://github.com/apache/spark/pull/49984

   ### What changes were proposed in this pull request?
   
   This PR proposes to implement the graceful deprecation of incorrect config 
introduced in SPARK-49699. 
   
   SPARK-49699 was included in Spark 3.5.4, hence we can't simply rename to fix 
the issue.
   
   Also, since the incorrect config is logged in offset log in streaming query, 
the fix isn't just easy like adding withAlternative and done. We need to 
manually handle the case where offset log contains the incorrect config, and 
set the value of incorrect config in the offset log into the new config. Once a 
single microbatch has planned after the restart (hence the above logic is 
applied), offset log will contain the "new" config and it will no longer refer 
to the incorrect config.
   
   That said, we can remove the incorrect config in the Spark version which we 
are confident that there will be no case users will upgrade from Spark 3.5.4 to 
that version.
   
   ### Why are the changes needed?
   
   We released an incorrect config and we want to rename it properly. While 
renaming, we don't also want to have any breakage on the existing streaming 
query.
   
   ### Does this PR introduce _any_ user-facing change?
   
   No. That is what this PR is aiming for.
   
   ### How was this patch tested?
   
   New UT.
   
   ### Was this patch authored or co-authored using generative AI tooling?
   
   No.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to