Skip to content

Commit ec5f953

Browse files
committed
Fix PostCommit_Java_ValidatesRunner_SparkStructuredStreaming
1 parent a70f1f3 commit ec5f953

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
{}

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)