(beam) branch master updated: Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming (#36810)

[yhu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 1aca8519a47 Fix 
PostCommit_Java_ValidatesRunner_SparkStructuredStreaming (#36810)
1aca8519a47 is described below

commit 1aca8519a47a697ca2c7a4e009703906affe0f41
Author: Yi Hu <ya...@google.com>
AuthorDate: Thu Nov 13 11:20:29 2025 -0500

    Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming (#36810)
---
 .../beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json  | 2 --
 runners/spark/spark_runner.gradle                                       | 2 +-
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json
 
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json
index 5a72b5d2a09..77f63217b86 100644
--- 
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json
+++ 
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json
@@ -1,6 +1,4 @@
 {
-  "https://github.com/apache/beam/pull/35213": "Eliminating getPane() in favor 
of getPaneInfo()",
-  "https://github.com/apache/beam/pull/35177": "Introducing 
WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to 
run",
   "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should 
run this test",
   "https://github.com/apache/beam/pull/31798": "noting that PR #31798 should 
run this test",
diff --git a/runners/spark/spark_runner.gradle 
b/runners/spark/spark_runner.gradle
index 037d46a31ed..ecdfc8f0f69 100644
--- a/runners/spark/spark_runner.gradle
+++ b/runners/spark/spark_runner.gradle
@@ -398,7 +398,7 @@ tasks.register("validatesStructuredStreamingRunnerBatch", 
Test) {
   systemProperties 
sparkTestProperties(["--runner":"SparkStructuredStreamingRunner", 
"--testMode":"true"])
   // Register various other classes used in tests
   systemProperty 'spark.kryo.classesToRegister',
-    'org.apache.beam.sdk.transforms.ViewTest$NonDeterministicStringCoder,' +
+    'org.apache.beam.sdk.transforms.MapViewTest$NonDeterministicStringCoder,' +
     
'org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.RegularImmutableList'
   jvmArgs += sparkTestJvmArgs()
   jvmArgs '-Xmx7g' // Increase memory heap in order to avoid OOM errors