Skip to content

Commit 3c20249

Browse files
committed
Fixup boot.go
1 parent de88282 commit 3c20249

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

sdks/java/container/boot.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -277,8 +277,12 @@ func main() {
277277
}
278278
}
279279
// Add trusted Avro serializable classes
280-
if serializableClasses, ok := pipelineOptions.GetStructValue().GetFields()["avroSerializableClasses"]; ok {
281-
args = append(args, "-Dorg.apache.avro.SERIALIZABLE_CLASSES="+strings.Join(serializableClasses.GetStringValue(), ",")
280+
if serializableClasses, ok := pipelineOptions.GetStructValue().GetFields()["avroSerializableClasses"]; ok {var stringSlice []string
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, ","))
282286
}
283287
}
284288
// Automatically open modules for Java 11+

0 commit comments

Comments
 (0)