From e8b4a48b78cd583097b8668afedc291f967c6726 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Thu, 13 Nov 2025 10:12:53 -0500 Subject: [PATCH] Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming --- ...ostCommit_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 5a72b5d2a094..77f63217b86d 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 037d46a31ed3..ecdfc8f0f697 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