You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2018/08/20 23:08:04 UTC

[beam] 01/01: Merge pull request #6249: [BEAM-5169] Add options for master URL and log level to Flink jobserver runShadow task.

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

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

commit 20aff13d36b4ac7d9b9a29fd9f6fb3e80a84214a
Merge: 31314f0 eb98549
Author: Thomas Weise <tw...@users.noreply.github.com>
AuthorDate: Mon Aug 20 16:07:58 2018 -0700

    Merge pull request #6249: [BEAM-5169] Add options for master URL and log level to Flink jobserver runShadow task.

 runners/flink/job-server/build.gradle | 4 ++++
 1 file changed, 4 insertions(+)

diff --cc runners/flink/job-server/build.gradle
index 0da1b89,b38b209..5e1e01a
--- a/runners/flink/job-server/build.gradle
+++ b/runners/flink/job-server/build.gradle
@@@ -64,10 -60,8 +66,12 @@@ runShadow 
  
    // Enable remote debugging.
    jvmArgs = ["-Xdebug", "-Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5005"]
+   if (project.hasProperty("logLevel"))
+     jvmArgs += ["-Dorg.slf4j.simpleLogger.defaultLogLevel=${project.property('logLevel')}"]
  }
  
 -createPortableValidatesRunnerTask(jobServerDriver: "org.apache.beam.runners.flink.FlinkJobServerDriver", testClasspathConfiguration: configurations.validatesPortableRunner)
 +createPortableValidatesRunnerTask(
 +        jobServerDriver: "org.apache.beam.runners.flink.FlinkJobServerDriver",
 +        jobServerConfig: "--clean-artifacts-per-job",
 +        testClasspathConfiguration: configurations.validatesPortableRunner
 +)