Repository: flink Updated Branches: refs/heads/master 92947f0d8 -> 631b6eb80
[FLINK-1372] [runtime] Adds EnvironmentInformation.logEnvironmentInfo method calls to JobManager's and TaskManager's main methods. This closes #329. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/631b6eb8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/631b6eb8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/631b6eb8 Branch: refs/heads/master Commit: 631b6eb804dc4a0236198574a8f8011ab2b6c8c2 Parents: 92947f0 Author: Till Rohrmann <[email protected]> Authored: Wed Jan 21 16:12:19 2015 +0100 Committer: Till Rohrmann <[email protected]> Committed: Thu Jan 22 12:08:18 2015 +0100 ---------------------------------------------------------------------- .../scala/org/apache/flink/runtime/jobmanager/JobManager.scala | 3 +++ .../scala/org/apache/flink/runtime/taskmanager/TaskManager.scala | 2 ++ 2 files changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/631b6eb8/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala index daf16ce..f456f42 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala @@ -32,6 +32,7 @@ import org.apache.flink.runtime.executiongraph.{Execution, ExecutionJobVertex, E import org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph import org.apache.flink.runtime.messages.ExecutionGraphMessages.JobStatusChanged import org.apache.flink.runtime.taskmanager.TaskManager +import org.apache.flink.runtime.util.EnvironmentInformation import org.apache.flink.runtime.{JobException, ActorLogMessages} import org.apache.flink.runtime.akka.AkkaUtils import org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager @@ -472,6 +473,8 @@ object JobManager { val PROFILER_NAME = "profiler" def main(args: Array[String]): Unit = { + EnvironmentInformation.logEnvironmentInfo(LOG, "JobManager") + val (hostname, port, configuration, executionMode) = parseArgs(args) val jobManagerSystem = AkkaUtils.createActorSystem(hostname, port, configuration) http://git-wip-us.apache.org/repos/asf/flink/blob/631b6eb8/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala index 6dca14a..0e953c2 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala @@ -577,6 +577,8 @@ object TaskManager { val HEARTBEAT_INTERVAL = 5000 millisecond def main(args: Array[String]): Unit = { + EnvironmentInformation.logEnvironmentInfo(LOG, "TaskManager") + val (hostname, port, configuration) = parseArgs(args) val (taskManagerSystem, _) = startActorSystemAndActor(hostname, port, configuration)
