[beam] branch master updated: [BEAM-10225] Add log message when starting job server

[ib...@apache.org]

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

ibzib 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 10c7d38  [BEAM-10225] Add log message when starting job server
     new 0c1d3db  Merge pull request #11961 from annaqin418/BEAM-10225-jobserver-log
10c7d38 is described below

commit 10c7d381bc4a67e4e06b08a448632ce682eabd0c
Author: Anna Qin <an...@google.com>
AuthorDate: Tue Jun 9 21:21:26 2020 +0000

    [BEAM-10225] Add log message when starting job server
---
 .../main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java b/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java
index 00d74f5..02f4e77 100644
--- a/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java
+++ b/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java
@@ -173,6 +173,7 @@ public abstract class JobServerDriver implements Runnable {
   public void run() {
     try {
       jobServer = createJobServer();
+      LOG.info("Job server now running, terminate with Ctrl+C");
       jobServer.getServer().awaitTermination();
     } catch (InterruptedException e) {
       LOG.warn("Job server interrupted", e);