[flink] branch master updated: [FLINK-11385][mesos] Remove legacy MesosJobManager

[ch...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 6e25b0c  [FLINK-11385][mesos] Remove legacy MesosJobManager
6e25b0c is described below

commit 6e25b0c79138fd96e50afbd3ce4c5b2bf59e2245
Author: ZILI CHEN <wa...@gmail.com>
AuthorDate: Thu Jan 31 21:23:12 2019 +0800

    [FLINK-11385][mesos] Remove legacy MesosJobManager
---
 .../runtime/clusterframework/MesosJobManager.scala | 91 ----------------------
 1 file changed, 91 deletions(-)

diff --git a/flink-mesos/src/main/scala/org/apache/flink/mesos/runtime/clusterframework/MesosJobManager.scala b/flink-mesos/src/main/scala/org/apache/flink/mesos/runtime/clusterframework/MesosJobManager.scala
deleted file mode 100644
index 972af35..0000000
--- a/flink-mesos/src/main/scala/org/apache/flink/mesos/runtime/clusterframework/MesosJobManager.scala
+++ /dev/null
@@ -1,91 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.mesos.runtime.clusterframework
-
-import java.util.concurrent.{Executor, ScheduledExecutorService}
-
-import akka.actor.ActorRef
-import org.apache.flink.configuration.{Configuration => FlinkConfiguration}
-import org.apache.flink.runtime.blob.BlobServer
-import org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory
-import org.apache.flink.runtime.clusterframework.ContaineredJobManager
-import org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager
-import org.apache.flink.runtime.executiongraph.restart.RestartStrategyFactory
-import org.apache.flink.runtime.instance.InstanceManager
-import org.apache.flink.runtime.jobmanager.SubmittedJobGraphStore
-import org.apache.flink.runtime.jobmanager.scheduler.{Scheduler => FlinkScheduler}
-import org.apache.flink.runtime.leaderelection.LeaderElectionService
-import org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup
-
-import scala.concurrent.duration._
-
-/** JobManager actor for execution on Mesos.
-  *
-  * @param flinkConfiguration Configuration object for the actor
-  * @param futureExecutor Execution context which is used to execute concurrent tasks in the
-  *                         [[org.apache.flink.runtime.executiongraph.ExecutionGraph]]
-  * @param ioExecutor for blocking io operations
-  * @param instanceManager Instance manager to manage the registered
-  *                        [[org.apache.flink.runtime.taskmanager.TaskManager]]
-  * @param scheduler Scheduler to schedule Flink jobs
-  * @param blobServer BLOB store for file uploads
-  * @param libraryCacheManager manages uploaded jar files and class paths
-  * @param archive Archive for finished Flink jobs
-  * @param restartStrategyFactory Restart strategy to be used in case of a job recovery
-  * @param timeout Timeout for futures
-  * @param leaderElectionService LeaderElectionService to participate in the leader election
-  */
-class MesosJobManager(
-    flinkConfiguration: FlinkConfiguration,
-    futureExecutor: ScheduledExecutorService,
-    ioExecutor: Executor,
-    instanceManager: InstanceManager,
-    scheduler: FlinkScheduler,
-    blobServer: BlobServer,
-    libraryCacheManager: BlobLibraryCacheManager,
-    archive: ActorRef,
-    restartStrategyFactory: RestartStrategyFactory,
-    timeout: FiniteDuration,
-    leaderElectionService: LeaderElectionService,
-    submittedJobGraphs : SubmittedJobGraphStore,
-    checkpointRecoveryFactory : CheckpointRecoveryFactory,
-    jobRecoveryTimeout: FiniteDuration,
-    jobManagerMetricGroup: JobManagerMetricGroup,
-    optRestAddress: Option[String])
-  extends ContaineredJobManager(
-    flinkConfiguration,
-    futureExecutor,
-    ioExecutor,
-    instanceManager,
-    scheduler,
-    blobServer,
-    libraryCacheManager,
-    archive,
-    restartStrategyFactory,
-    timeout,
-    leaderElectionService,
-    submittedJobGraphs,
-    checkpointRecoveryFactory,
-    jobRecoveryTimeout,
-    jobManagerMetricGroup,
-    optRestAddress) {
-
-  val jobPollingInterval: FiniteDuration = 5 seconds
-
-}