[GitHub] [spark] HeartSaVioR opened a new pull request #26300: [SPARK-29642][SS] Change the element type of underlying array to UnsafeRow for ContinuousRecordEndpoint

[GitBox <gi...@apache.org>]

HeartSaVioR opened a new pull request #26300: [SPARK-29642][SS] Change the element type of underlying array to UnsafeRow for ContinuousRecordEndpoint
URL: https://github.com/apache/spark/pull/26300
 
 
   ### What changes were proposed in this pull request?
   
   This patch fixes the bug that `ContinuousMemoryStream[String]` throws error regarding ClassCastException - cast String to UTFString. This is because ContinuousMemoryStream and ContinuousRecordEndpoint uses origin input as it is for Row, and encoding is missing here.
   
   To force encoding, this patch changes the element type of underlying array to UnsafeRow instead of Any for ContinuousRecordEndpoint - ContinuousMemoryStream and TextSocketContinuousStream are modified to reflect the change.
   
   ### Why are the changes needed?
   
   Above session describes the bug.
   
   ### Does this PR introduce any user-facing change?
   
   No.
   
   ### How was this patch tested?
   
   Add new UT to check for availability on couple of types.

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

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