This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 00828db664f Adds GCP core dependency to the test expansion service
(#24308)
add e0d0a72f559 [Spark dataset runner] Fix translation to run in the
evaluation thread as well so exceptions are handled properly (closes #24330)
add 84d47ef4a2f Merge pull request #24331: [Spark dataset runner] Fix
handling of exceptions during translation
No new revisions were added by this update.
Summary of changes:
.../SparkStructuredStreamingPipelineResult.java | 7 +--
.../SparkStructuredStreamingRunner.java | 58 ++++++++++++----------
2 files changed, 35 insertions(+), 30 deletions(-)
