Skip to content

Commit 1aca851

Browse files
authored
Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming (#36810)
1 parent ce1b1dc commit 1aca851

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,4 @@
11
{
2-
"https://github.com/apache/beam/pull/35213": "Eliminating getPane() in favor of getPaneInfo()",
3-
"https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
42
"comment": "Modify this file in a trivial way to cause this test suite to run",
53
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
64
"https://github.com/apache/beam/pull/31798": "noting that PR #31798 should run this test",

runners/spark/spark_runner.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -398,7 +398,7 @@ tasks.register("validatesStructuredStreamingRunnerBatch", Test) {
398398
systemProperties sparkTestProperties(["--runner":"SparkStructuredStreamingRunner", "--testMode":"true"])
399399
// Register various other classes used in tests
400400
systemProperty 'spark.kryo.classesToRegister',
401-
'org.apache.beam.sdk.transforms.ViewTest$NonDeterministicStringCoder,' +
401+
'org.apache.beam.sdk.transforms.MapViewTest$NonDeterministicStringCoder,' +
402402
'org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.RegularImmutableList'
403403
jvmArgs += sparkTestJvmArgs()
404404
jvmArgs '-Xmx7g' // Increase memory heap in order to avoid OOM errors

0 commit comments

Comments
 (0)