[beam] branch master updated: [BEAM-11634] Give JobInvoker threads unique names.

[goenka]

This is an automated email from the ASF dual-hosted git repository.

goenka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d19510  [BEAM-11634] Give JobInvoker threads unique names.
     new a44768f  Merge pull request #13746 from ibzib/BEAM-11634
9d19510 is described below

commit 9d195103c243ccb1cd8ead3f52f768d86a49cb73
Author: Kyle Weaver <kcwea...@google.com>
AuthorDate: Tue Jan 12 19:59:50 2021 -0800

    [BEAM-11634] Give JobInvoker threads unique names.
---
 .../src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java    | 2 +-
 .../src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java
 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java
index e6bc7f7..0914015 100644
--- 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java
+++ 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java
@@ -49,7 +49,7 @@ public class FlinkJobInvoker extends JobInvoker {
   private final FlinkJobServerDriver.FlinkServerConfiguration serverConfig;
 
   protected FlinkJobInvoker(FlinkJobServerDriver.FlinkServerConfiguration 
serverConfig) {
-    super("flink-runner-job-invoker");
+    super("flink-runner-job-invoker-%d");
     this.serverConfig = serverConfig;
   }
 
diff --git 
a/runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java
 
b/runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java
index 79c0633..dd57a6c 100644
--- 
a/runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java
+++ 
b/runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java
@@ -49,7 +49,7 @@ public class SparkJobInvoker extends JobInvoker {
   }
 
   private SparkJobInvoker(SparkJobServerDriver.SparkServerConfiguration 
configuration) {
-    super("spark-runner-job-invoker");
+    super("spark-runner-job-invoker-%d");
     this.configuration = configuration;
   }