beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From goe...@apache.org
Subject [beam] branch master updated: [BEAM-11634] Give JobInvoker threads unique names.
Date Sat, 30 Jan 2021 00:44:41 GMT
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 <kcweaver@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;
   }
 


Mime
View raw message