Copyright adjustments merged into code. This closes: #7 Review: https://github.com/apache/incubator-myriad/pull/7
Project: http://git-wip-us.apache.org/repos/asf/incubator-myriad/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-myriad/commit/766f7213 Tree: http://git-wip-us.apache.org/repos/asf/incubator-myriad/tree/766f7213 Diff: http://git-wip-us.apache.org/repos/asf/incubator-myriad/diff/766f7213 Branch: refs/heads/master Commit: 766f7213b5243758800f9501b6dfb879a6f44528 Parents: e184194 869d4aa Author: Ken Sipe <kens...@gmail.com> Authored: Fri Oct 16 10:38:06 2015 -0500 Committer: Ken Sipe <kens...@gmail.com> Committed: Fri Oct 16 10:38:06 2015 -0500 ---------------------------------------------------------------------- LICENSE | 268 +++++++++++++++---- NOTICE | 28 +- docs/myriad-dev.md | 2 +- docs/vagrant.md | 4 +- .../executor/ContainerTaskStatusRequest.java | 29 +- .../myriad/executor/MyriadExecutorDefaults.java | 29 +- .../com/ebay/myriad/executor/NMTaskConfig.java | 29 +- .../ebay/myriad/executor/MyriadExecutor.java | 29 +- .../executor/MyriadExecutorAuxService.java | 33 +-- .../java/com/ebay/myriad/DisruptorManager.java | 29 +- .../src/main/java/com/ebay/myriad/Main.java | 31 ++- .../main/java/com/ebay/myriad/MesosModule.java | 29 +- .../main/java/com/ebay/myriad/MyriadModule.java | 29 +- .../com/ebay/myriad/api/ClustersResource.java | 29 +- .../ebay/myriad/api/ConfigurationResource.java | 31 ++- .../ebay/myriad/api/SchedulerStateResource.java | 29 +- .../api/model/FlexDownClusterRequest.java | 29 +- .../myriad/api/model/FlexUpClusterRequest.java | 29 +- .../api/model/GetSchedulerStateResponse.java | 29 +- .../configuration/MyriadConfiguration.java | 29 +- .../MyriadExecutorConfiguration.java | 18 ++ .../configuration/NodeManagerConfiguration.java | 18 ++ .../ebay/myriad/health/HealthCheckUtils.java | 29 +- .../myriad/health/MesosDriverHealthCheck.java | 29 +- .../myriad/health/MesosMasterHealthCheck.java | 29 +- .../myriad/health/ZookeeperHealthCheck.java | 29 +- .../myriad/policy/LeastAMNodesFirstPolicy.java | 18 ++ .../ebay/myriad/policy/NodeScaleDownPolicy.java | 18 ++ .../scheduler/DownloadNMExecutorCLGenImpl.java | 15 +- .../scheduler/ExecutorCommandLineGenerator.java | 15 +- .../com/ebay/myriad/scheduler/MyriadDriver.java | 29 +- .../myriad/scheduler/MyriadDriverManager.java | 29 +- .../ebay/myriad/scheduler/MyriadOperations.java | 29 +- .../ebay/myriad/scheduler/MyriadScheduler.java | 29 +- .../myriad/scheduler/NMExecutorCLGenImpl.java | 15 +- .../java/com/ebay/myriad/scheduler/NMPorts.java | 18 ++ .../com/ebay/myriad/scheduler/NMProfile.java | 29 +- .../ebay/myriad/scheduler/NMProfileManager.java | 29 +- .../com/ebay/myriad/scheduler/Rebalancer.java | 29 +- .../ebay/myriad/scheduler/ReconcileService.java | 18 ++ .../ebay/myriad/scheduler/SchedulerUtils.java | 31 ++- .../com/ebay/myriad/scheduler/TaskFactory.java | 18 ++ .../ebay/myriad/scheduler/TaskTerminator.java | 29 +- .../com/ebay/myriad/scheduler/TaskUtils.java | 29 +- .../scheduler/event/DisconnectedEvent.java | 29 +- .../event/DisconnectedEventFactory.java | 18 ++ .../ebay/myriad/scheduler/event/ErrorEvent.java | 29 +- .../scheduler/event/ErrorEventFactory.java | 18 ++ .../scheduler/event/ExecutorLostEvent.java | 29 +- .../event/ExecutorLostEventFactory.java | 18 ++ .../scheduler/event/FrameworkMessageEvent.java | 29 +- .../event/FrameworkMessageEventFactory.java | 18 ++ .../scheduler/event/OfferRescindedEvent.java | 29 +- .../event/OfferRescindedEventFactory.java | 18 ++ .../scheduler/event/ReRegisteredEvent.java | 29 +- .../event/ReRegisteredEventFactory.java | 18 ++ .../myriad/scheduler/event/RegisteredEvent.java | 29 +- .../scheduler/event/RegisteredEventFactory.java | 18 ++ .../scheduler/event/ResourceOffersEvent.java | 29 +- .../event/ResourceOffersEventFactory.java | 18 ++ .../myriad/scheduler/event/SlaveLostEvent.java | 29 +- .../scheduler/event/SlaveLostEventFactory.java | 18 ++ .../scheduler/event/StatusUpdateEvent.java | 31 ++- .../event/StatusUpdateEventFactory.java | 18 ++ .../handlers/DisconnectedEventHandler.java | 29 +- .../event/handlers/ErrorEventHandler.java | 29 +- .../handlers/ExecutorLostEventHandler.java | 29 +- .../handlers/FrameworkMessageEventHandler.java | 29 +- .../handlers/OfferRescindedEventHandler.java | 29 +- .../handlers/ReRegisteredEventHandler.java | 29 +- .../event/handlers/RegisteredEventHandler.java | 29 +- .../handlers/ResourceOffersEventHandler.java | 29 +- .../event/handlers/SlaveLostEventHandler.java | 29 +- .../handlers/StatusUpdateEventHandler.java | 29 +- .../myriad/scheduler/fgs/ConsumedOffer.java | 18 ++ .../scheduler/fgs/NMHeartBeatHandler.java | 18 ++ .../com/ebay/myriad/scheduler/fgs/Node.java | 18 ++ .../ebay/myriad/scheduler/fgs/NodeStore.java | 18 ++ .../ebay/myriad/scheduler/fgs/OfferFeed.java | 18 ++ .../scheduler/fgs/OfferLifecycleManager.java | 18 ++ .../ebay/myriad/scheduler/fgs/OfferUtils.java | 18 ++ .../scheduler/fgs/YarnNodeCapacityManager.java | 18 ++ .../scheduler/yarn/MyriadCapacityScheduler.java | 18 ++ .../scheduler/yarn/MyriadFairScheduler.java | 18 ++ .../scheduler/yarn/MyriadFifoScheduler.java | 18 ++ .../scheduler/yarn/RMNodeEventHandler.java | 18 ++ .../yarn/interceptor/BaseInterceptor.java | 18 ++ .../yarn/interceptor/CompositeInterceptor.java | 18 ++ .../yarn/interceptor/InterceptorRegistry.java | 18 ++ .../MyriadInitializationInterceptor.java | 18 ++ .../interceptor/YarnSchedulerInterceptor.java | 18 ++ .../java/com/ebay/myriad/state/Cluster.java | 29 +- .../java/com/ebay/myriad/state/MyriadState.java | 18 ++ .../com/ebay/myriad/state/MyriadStateStore.java | 15 +- .../java/com/ebay/myriad/state/NodeTask.java | 29 +- .../com/ebay/myriad/state/SchedulerState.java | 29 +- .../myriad/state/utils/ByteBufferSupport.java | 17 +- .../ebay/myriad/state/utils/StoreContext.java | 15 +- .../myriad/webapp/HttpConnectorProvider.java | 18 ++ .../ebay/myriad/webapp/MyriadServletModule.java | 18 ++ .../com/ebay/myriad/webapp/MyriadWebServer.java | 18 ++ .../ebay/myriad/webapp/WebAppGuiceModule.java | 18 ++ .../recovery/MyriadFileSystemRMStateStore.java | 15 +- .../src/main/resources/webapp/index.html | 18 ++ .../src/main/resources/webapp/public/index.html | 18 ++ .../src/main/resources/yarn-site-default.xml | 2 +- .../test/java/com/ebay/myriad/MesosModule.java | 29 +- .../myriad/scheduler/TestMyriadScheduler.java | 18 ++ 108 files changed, 1903 insertions(+), 842 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/Main.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/api/ClustersResource.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/api/model/FlexDownClusterRequest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/api/model/FlexUpClusterRequest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/policy/LeastAMNodesFirstPolicy.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/policy/NodeScaleDownPolicy.java ---------------------------------------------------------------------- diff --cc myriad-scheduler/src/main/java/com/ebay/myriad/policy/NodeScaleDownPolicy.java index f40d360,4aaced1..e6db190 --- a/myriad-scheduler/src/main/java/com/ebay/myriad/policy/NodeScaleDownPolicy.java +++ b/myriad-scheduler/src/main/java/com/ebay/myriad/policy/NodeScaleDownPolicy.java @@@ -1,7 -1,23 +1,25 @@@ + /** + * 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 com.ebay.myriad.policy; +import org.apache.mesos.Protos; + import java.util.List; /** http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/MyriadOperations.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/Rebalancer.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/SchedulerUtils.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/TaskTerminator.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/scheduler/event/handlers/ResourceOffersEventHandler.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/state/NodeTask.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/state/SchedulerState.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/766f7213/myriad-scheduler/src/main/java/com/ebay/myriad/state/utils/ByteBufferSupport.java ----------------------------------------------------------------------
