You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2021/01/30 00:44:41 UTC
[beam] branch master updated: [BEAM-11634] Give JobInvoker threads
unique names.
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 <kc...@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;
}