OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Go SDK: How are re-starts handled?


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.