Skip to content

[SPARK-52428] Harden streaming and session error handling#26

Open
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:hardening-streaming-session-error-handling
Open

[SPARK-52428] Harden streaming and session error handling#26
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:hardening-streaming-session-error-handling

Conversation

@rafafrdz
Copy link
Copy Markdown

Summary

  • Replace unwrap() on output_mode, query_id, operation_start_resp in streaming with ok_or() + ?
  • Change StreamingQuery::new() to return Result<Self, SparkError>
  • Replace unwrap() on sql_command_result and relation in SparkSession::sql()
  • Replace unwrap() on to_json_object empty vec access

Test plan

  • cargo build passes
  • cargo test unit tests pass
  • cargo fmt -- --check passes

@rafafrdz rafafrdz force-pushed the hardening-streaming-session-error-handling branch from ddff2a9 to 9554be8 Compare March 29, 2026 08:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant