Fixup boot.go

clairemcginty · clairemcginty · commit 6bd13e196c3c · 2025-11-13T10:53:24.000-05:00
diff --git a/sdks/java/container/boot.go b/sdks/java/container/boot.go
@@ -278,7 +278,11 @@ func main() {
 		}
 		// Add trusted Avro serializable classes
 		if serializableClasses, ok := pipelineOptions.GetStructValue().GetFields()["avroSerializableClasses"]; ok {
-			args = append(args, "-Dorg.apache.avro.SERIALIZABLE_CLASSES="+strings.Join(serializableClasses.GetStringValue(), ",")
+			var serializableClassesSlice []string
+			for _, cls := range serializableClasses.GetListValue().getValues() {
+				serializableClassesSlice = append(serializableClassesSlice, cls.GetStringValue())
+			}
+			args = append(args, "-Dorg.apache.avro.SERIALIZABLE_CLASSES="+strings.Join(serializableClassesSlice, ","))
 		}
 	}
 	// Automatically open modules for Java 11+

Original file line number	Diff line number	Diff line change
`@@ -278,7 +278,11 @@ func main() {`
`278`	`278`	`}`
`279`	`279`	`// Add trusted Avro serializable classes`
`280`	`280`	`if serializableClasses, ok := pipelineOptions.GetStructValue().GetFields()["avroSerializableClasses"]; ok {`
`281`		`- args = append(args, "-Dorg.apache.avro.SERIALIZABLE_CLASSES="+strings.Join(serializableClasses.GetStringValue(), ",")`
	`281`	`+ var serializableClassesSlice []string`
	`282`	`+ for _, cls := range serializableClasses.GetListValue().getValues() {`
	`283`	`+ serializableClassesSlice = append(serializableClassesSlice, cls.GetStringValue())`
	`284`	`+ }`
	`285`	`+ args = append(args, "-Dorg.apache.avro.SERIALIZABLE_CLASSES="+strings.Join(serializableClassesSlice, ","))`
`282`	`286`	`}`
`283`	`287`	`}`
`284`	`288`	`// Automatically open modules for Java 11+`