Go SDK: How are re-starts handled?

[eduardo . morales]

If I have a k8s process launching dataflow pipelines, what happens when the 
process is restarted? Can Apache Beam detect a running pipeline and join 
accordingly? or will the pipeline be duplicated?

Thanks in advance.