@@ -227,19 +227,20 @@ func main() {
227227 if pipelineOptions , ok := info .GetPipelineOptions ().GetFields ()["options" ]; ok {
228228 if heapDumpOption , ok := pipelineOptions .GetStructValue ().GetFields ()["enableHeapDumps" ]; ok {
229229 if heapDumpOption .GetBoolValue () {
230- args = append (args , "-XX:+HeapDumpOnOutOfMemoryError" ,
231- "-Dbeam.fn.heap_dump_dir=" + filepath .Join (dir , "heapdumps" ),
232- "-XX:HeapDumpPath=" + filepath .Join (dir , "heapdumps" , "heap_dump.hprof" ))
230+ args = append (args , "-XX:+HeapDumpOnOutOfMemoryError" ,
231+ "-Dbeam.fn.heap_dump_dir=" + filepath .Join (dir , "heapdumps" ),
232+ "-XX:HeapDumpPath=" + filepath .Join (dir , "heapdumps" , "heap_dump.hprof" ))
233233 }
234234 }
235235 }
236236
237237 // Apply meta options
238238 const metaDir = "/opt/apache/beam/options"
239239
240- // Note: Error is unchecked, so parsing errors won't abort container.
241- // TODO: verify if it's intentional or not.
242- metaOptions , _ := LoadMetaOptions (ctx , logger , metaDir )
240+ metaOptions , err := LoadMetaOptions (ctx , logger , metaDir )
241+ if err != nil {
242+ logger .Errorf (ctx , "LoadMetaOptions failed: %v" , err )
243+ }
243244
244245 javaOptions := BuildOptions (ctx , logger , metaOptions )
245246 // (1) Add custom jvm arguments: "-server -Xmx1324 -XXfoo .."
0 commit comments