This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new 040df88 [FLINK-22352][mesos] Deprecates Mesos support
040df88 is described below
commit 040df885147e30ae748c141e4c34aa2ae3b38c16
Author: Matthias Pohl <[email protected]>
AuthorDate: Mon Apr 19 12:13:49 2021 +0200
[FLINK-22352][mesos] Deprecates Mesos support
---
docs/content.zh/docs/deployment/config.md | 5 +++++
docs/content.zh/docs/deployment/resource-providers/mesos.md | 5 +++++
docs/content/docs/deployment/config.md | 5 +++++
docs/content/docs/deployment/resource-providers/mesos.md | 5 +++++
.../org/apache/flink/mesos/configuration/MesosOptions.java | 8 +++++++-
.../flink/mesos/entrypoint/MesosJobClusterEntrypoint.java | 11 ++++++++++-
.../flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java | 11 ++++++++++-
.../flink/mesos/entrypoint/MesosTaskExecutorRunner.java | 8 +++++++-
.../mesos/runtime/clusterframework/LaunchableMesosWorker.java | 4 ++++
.../flink/mesos/runtime/clusterframework/MesosConfigKeys.java | 8 +++++++-
.../runtime/clusterframework/MesosResourceManagerActions.java | 4 ++++
.../clusterframework/MesosResourceManagerActorFactory.java | 8 +++++++-
.../MesosResourceManagerActorFactoryImpl.java | 8 +++++++-
.../runtime/clusterframework/MesosResourceManagerDriver.java | 8 +++++++-
.../runtime/clusterframework/MesosResourceManagerFactory.java | 4 ++++
.../runtime/clusterframework/MesosTaskManagerParameters.java | 4 ++++
.../clusterframework/MesosWorkerResourceSpecFactory.java | 8 +++++++-
.../runtime/clusterframework/RegisteredMesosWorkerNode.java | 4 ++++
.../clusterframework/services/AbstractMesosServices.java | 8 +++++++-
.../runtime/clusterframework/services/MesosServices.java | 8 +++++++-
.../runtime/clusterframework/services/MesosServicesUtils.java | 8 +++++++-
.../clusterframework/services/StandaloneMesosServices.java | 8 +++++++-
.../clusterframework/services/ZooKeeperMesosServices.java | 8 +++++++-
.../runtime/clusterframework/store/MesosWorkerStore.java | 8 +++++++-
.../clusterframework/store/StandaloneMesosWorkerStore.java | 8 +++++++-
.../clusterframework/store/ZooKeeperMesosWorkerStore.java | 8 +++++++-
.../org/apache/flink/mesos/util/MesosArtifactResolver.java | 8 +++++++-
.../java/org/apache/flink/mesos/util/MesosArtifactServer.java | 4 ++++
.../org/apache/flink/mesos/util/MesosArtifactServerImpl.java | 8 +++++++-
.../java/org/apache/flink/mesos/util/MesosConfiguration.java | 8 +++++++-
.../org/apache/flink/mesos/util/MesosResourceAllocation.java | 4 ++++
.../src/main/java/org/apache/flink/mesos/util/MesosUtils.java | 8 +++++++-
32 files changed, 201 insertions(+), 21 deletions(-)
diff --git a/docs/content.zh/docs/deployment/config.md
b/docs/content.zh/docs/deployment/config.md
index 563c87d..92b5903 100644
--- a/docs/content.zh/docs/deployment/config.md
+++ b/docs/content.zh/docs/deployment/config.md
@@ -218,6 +218,11 @@ The options in this section are necessary for setups where
Flink itself actively
### Mesos
+{{< hint warning >}}
+Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in
the future (see
+[FLINK-22352](https://issues.apache.org/jira/browse/FLINK-22352) for further
details).
+{{< /hint >}}
+
{{< generated/mesos_configuration >}}
**Mesos TaskManager**
diff --git a/docs/content.zh/docs/deployment/resource-providers/mesos.md
b/docs/content.zh/docs/deployment/resource-providers/mesos.md
index 51b7468..be2a63c 100644
--- a/docs/content.zh/docs/deployment/resource-providers/mesos.md
+++ b/docs/content.zh/docs/deployment/resource-providers/mesos.md
@@ -27,6 +27,11 @@ under the License.
# Flink on Mesos
+{{< hint warning >}}
+Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in
the future (see
+[FLINK-22352](https://issues.apache.org/jira/browse/FLINK-22352) for further
details).
+{{< /hint >}}
+
## Getting Started
This *Getting Started* section guides you through setting up a fully
functional Flink Cluster on Mesos.
diff --git a/docs/content/docs/deployment/config.md
b/docs/content/docs/deployment/config.md
index 8c6088a..3310a15 100644
--- a/docs/content/docs/deployment/config.md
+++ b/docs/content/docs/deployment/config.md
@@ -219,6 +219,11 @@ The options in this section are necessary for setups where
Flink itself actively
### Mesos
+{{< hint warning >}}
+Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in
the future (see
+[FLINK-22352](https://issues.apache.org/jira/browse/FLINK-22352) for further
details).
+{{< /hint >}}
+
{{< generated/mesos_configuration >}}
**Mesos TaskManager**
diff --git a/docs/content/docs/deployment/resource-providers/mesos.md
b/docs/content/docs/deployment/resource-providers/mesos.md
index 1c536c0..2148290 100644
--- a/docs/content/docs/deployment/resource-providers/mesos.md
+++ b/docs/content/docs/deployment/resource-providers/mesos.md
@@ -27,6 +27,11 @@ under the License.
# Flink on Mesos
+{{< hint warning >}}
+Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in
the future (see
+[FLINK-22352](https://issues.apache.org/jira/browse/FLINK-22352) for further
details).
+{{< /hint >}}
+
## Getting Started
This *Getting Started* section guides you through setting up a fully
functional Flink Cluster on Mesos.
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/configuration/MesosOptions.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/configuration/MesosOptions.java
index 8e0bca0..121940b 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/configuration/MesosOptions.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/configuration/MesosOptions.java
@@ -24,7 +24,13 @@ import
org.apache.flink.configuration.description.TextElement;
import static org.apache.flink.configuration.ConfigOptions.key;
-/** The set of configuration options relating to mesos settings. */
+/**
+ * The set of configuration options relating to mesos settings.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosOptions {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
index ceb46c1..4edea6d 100755
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
@@ -40,7 +40,13 @@ import org.apache.flink.runtime.util.SignalHandler;
import java.io.IOException;
import java.util.concurrent.CompletableFuture;
-/** Entry point for Mesos per-job clusters. */
+/**
+ * Entry point for Mesos per-job clusters.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosJobClusterEntrypoint extends JobClusterEntrypoint {
private MesosConfiguration schedulerConfiguration;
@@ -97,6 +103,9 @@ public class MesosJobClusterEntrypoint extends
JobClusterEntrypoint {
SignalHandler.register(LOG);
JvmShutdownSafeguard.installAsShutdownHook(LOG);
+ LOG.warn(
+ "Mesos support was deprecated in Flink 1.13 and is subject to
removal in the future (see FLINK-22352 for further details).");
+
// load configuration incl. dynamic properties
Configuration dynamicProperties =
ClusterEntrypointUtils.parseParametersOrExit(
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java
index c8529d1..12ae3e8 100755
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java
@@ -38,7 +38,13 @@ import org.apache.flink.runtime.util.SignalHandler;
import java.util.concurrent.CompletableFuture;
-/** Entry point for Mesos session clusters. */
+/**
+ * Entry point for Mesos session clusters.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosSessionClusterEntrypoint extends SessionClusterEntrypoint {
private MesosConfiguration mesosConfig;
@@ -91,6 +97,9 @@ public class MesosSessionClusterEntrypoint extends
SessionClusterEntrypoint {
SignalHandler.register(LOG);
JvmShutdownSafeguard.installAsShutdownHook(LOG);
+ LOG.warn(
+ "Mesos support was deprecated in Flink 1.13 and is subject to
removal in the future (see FLINK-22352 for further details).");
+
// load configuration incl. dynamic properties
Configuration dynamicProperties =
ClusterEntrypointUtils.parseParametersOrExit(
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java
index 3683f45..9cc723b 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java
@@ -33,7 +33,13 @@ import org.apache.commons.cli.PosixParser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/** The entry point for running a TaskManager in a Mesos container. */
+/**
+ * The entry point for running a TaskManager in a Mesos container.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosTaskExecutorRunner {
private static final Logger LOG =
LoggerFactory.getLogger(MesosTaskExecutorRunner.class);
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
index b0b5c95..e355e2c 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
@@ -63,7 +63,11 @@ import static
org.apache.flink.mesos.configuration.MesosOptions.PORT_ASSIGNMENTS
*
* <p>Translates the abstract {@link ContainerSpecification} into a concrete
Mesos-specific {@link
* Protos.TaskInfo}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public class LaunchableMesosWorker implements LaunchableTask {
protected static final Logger LOG =
LoggerFactory.getLogger(LaunchableMesosWorker.class);
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java
index a23fa27..61d3fc4 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java
@@ -18,7 +18,13 @@
package org.apache.flink.mesos.runtime.clusterframework;
-/** The Mesos environment variables used for settings of the containers. */
+/**
+ * The Mesos environment variables used for settings of the containers.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosConfigKeys {
// ------------------------------------------------------------------------
// Environment variable names
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActions.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActions.java
index 481adbf..dc5fc5d 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActions.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActions.java
@@ -28,7 +28,11 @@ import
org.apache.flink.mesos.scheduler.messages.AcceptOffers;
*
* <p>These are called by the MesosResourceManager components such as {@link
LaunchCoordinator}, and
* {@link TaskMonitor}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public interface MesosResourceManagerActions {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactory.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactory.java
index a82cea5..052017a 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactory.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactory.java
@@ -30,7 +30,13 @@ import java.util.concurrent.CompletableFuture;
import scala.concurrent.duration.FiniteDuration;
-/** Factory class for actors used in mesos deployment. */
+/**
+ * Factory class for actors used in mesos deployment.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public interface MesosResourceManagerActorFactory {
/** Create self actor for mesos resource manager. */
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactoryImpl.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactoryImpl.java
index f78a70a..2eb6801 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactoryImpl.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerActorFactoryImpl.java
@@ -42,7 +42,13 @@ import java.util.concurrent.CompletableFuture;
import scala.concurrent.duration.FiniteDuration;
-/** Implementation of {@link MesosResourceManagerActorFactory}. */
+/**
+ * Implementation of {@link MesosResourceManagerActorFactory}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosResourceManagerActorFactoryImpl implements
MesosResourceManagerActorFactory {
private static final Logger LOG =
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
index 188cbc0..8868b60 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
@@ -76,7 +76,13 @@ import java.util.stream.Collectors;
import scala.Option;
import scala.concurrent.duration.FiniteDuration;
-/** Implementation of {@link ResourceManagerDriver} for Mesos deployment. */
+/**
+ * Implementation of {@link ResourceManagerDriver} for Mesos deployment.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosResourceManagerDriver
extends AbstractResourceManagerDriver<RegisteredMesosWorkerNode> {
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java
index 3c1cc18..bd25b80 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java
@@ -38,7 +38,11 @@ import javax.annotation.Nullable;
/**
* {@link ActiveResourceManagerFactory} implementation which creates {@link
ActiveResourceManager}
* with {@link MesosResourceManagerDriver}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public class MesosResourceManagerFactory
extends ActiveResourceManagerFactory<RegisteredMesosWorkerNode> {
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
index 3b9bd9d..c01e229 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
@@ -47,7 +47,11 @@ import static
org.apache.flink.configuration.ConfigOptions.key;
*
* <p>These parameters are in addition to the common parameters provided by
{@link
* ContaineredTaskManagerParameters}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public class MesosTaskManagerParameters {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosWorkerResourceSpecFactory.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosWorkerResourceSpecFactory.java
index 854b39e..a1f2030 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosWorkerResourceSpecFactory.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosWorkerResourceSpecFactory.java
@@ -24,7 +24,13 @@ import
org.apache.flink.runtime.clusterframework.TaskExecutorProcessUtils;
import org.apache.flink.runtime.resourcemanager.WorkerResourceSpec;
import org.apache.flink.runtime.resourcemanager.WorkerResourceSpecFactory;
-/** Implementation of {@link WorkerResourceSpecFactory} for Mesos deployments.
*/
+/**
+ * Implementation of {@link WorkerResourceSpecFactory} for Mesos deployments.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosWorkerResourceSpecFactory extends WorkerResourceSpecFactory {
public static final MesosWorkerResourceSpecFactory INSTANCE =
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.java
index 9c5045b..ba00029 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.java
@@ -27,7 +27,11 @@ import java.io.Serializable;
/**
* A representation of a registered Mesos task managed by the {@link
MesosResourceManagerDriver}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public class RegisteredMesosWorkerNode implements Serializable,
ResourceIDRetrievable {
private static final long serialVersionUID = 2;
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java
index 8ba4af1..0142e2d 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/AbstractMesosServices.java
@@ -32,7 +32,13 @@ import org.apache.mesos.SchedulerDriver;
import static org.apache.flink.util.Preconditions.checkNotNull;
-/** An abstract implementation of {@link MesosServices}. */
+/**
+ * An abstract implementation of {@link MesosServices}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public abstract class AbstractMesosServices implements MesosServices {
private final ActorSystem actorSystem;
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServices.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServices.java
index 2eb4763..8c128e4 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServices.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServices.java
@@ -28,7 +28,13 @@ import akka.actor.ActorSystem;
import org.apache.mesos.Scheduler;
import org.apache.mesos.SchedulerDriver;
-/** Service factory interface for Mesos. */
+/**
+ * Service factory interface for Mesos.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public interface MesosServices {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java
index 651bfef..1da03cd 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java
@@ -31,7 +31,13 @@ import akka.actor.ActorSystem;
import java.util.UUID;
-/** Utilities for the {@link MesosServices}. */
+/**
+ * Utilities for the {@link MesosServices}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosServicesUtils {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/StandaloneMesosServices.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/StandaloneMesosServices.java
index 1335af2..b2033ed 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/StandaloneMesosServices.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/StandaloneMesosServices.java
@@ -25,7 +25,13 @@ import org.apache.flink.mesos.util.MesosArtifactServer;
import akka.actor.ActorSystem;
-/** {@link MesosServices} implementation for the standalone mode. */
+/**
+ * {@link MesosServices} implementation for the standalone mode.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class StandaloneMesosServices extends AbstractMesosServices {
protected StandaloneMesosServices(ActorSystem actorSystem,
MesosArtifactServer artifactServer) {
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/ZooKeeperMesosServices.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/ZooKeeperMesosServices.java
index 147ca2c..aa76329 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/ZooKeeperMesosServices.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/ZooKeeperMesosServices.java
@@ -34,7 +34,13 @@ import org.apache.flink.util.Preconditions;
import akka.actor.ActorSystem;
-/** {@link MesosServices} implementation for the ZooKeeper high availability
based mode. */
+/**
+ * {@link MesosServices} implementation for the ZooKeeper high availability
based mode.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class ZooKeeperMesosServices extends AbstractMesosServices {
// Factory to create ZooKeeper utility classes
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
index 863119a..5c826c6 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
@@ -29,7 +29,13 @@ import scala.Option;
import static java.util.Objects.requireNonNull;
-/** A store of Mesos workers and associated framework information. */
+/**
+ * A store of Mesos workers and associated framework information.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public interface MesosWorkerStore {
/** The template for naming the worker. */
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java
index dc55953..d078011 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java
@@ -27,7 +27,13 @@ import java.util.Map;
import scala.Option;
-/** A standalone Mesos worker store. */
+/**
+ * A standalone Mesos worker store.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class StandaloneMesosWorkerStore implements MesosWorkerStore {
private Option<Protos.FrameworkID> frameworkID = Option.empty();
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
index 0b14aef..624b962 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
@@ -42,7 +42,13 @@ import scala.Option;
import static org.apache.flink.util.Preconditions.checkNotNull;
import static org.apache.flink.util.Preconditions.checkState;
-/** A ZooKeeper-backed Mesos worker store. */
+/**
+ * A ZooKeeper-backed Mesos worker store.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class ZooKeeperMesosWorkerStore implements MesosWorkerStore {
private static final Logger LOG =
LoggerFactory.getLogger(ZooKeeperMesosWorkerStore.class);
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactResolver.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactResolver.java
index 739f048..b6eb277 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactResolver.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactResolver.java
@@ -24,7 +24,13 @@ import java.net.URL;
import scala.Option;
-/** An interface for resolving artifact URIs. */
+/**
+ * An interface for resolving artifact URIs.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public interface MesosArtifactResolver {
Option<URL> resolve(Path remoteFile);
}
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
index d9ac759..b88fa92 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
@@ -29,7 +29,11 @@ import java.net.URL;
*
* <p>More information: http://mesos.apache.org/documentation/latest/fetcher/
* http://mesos.apache.org/documentation/latest/fetcher-cache-internals/
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public interface MesosArtifactServer extends MesosArtifactResolver {
/**
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServerImpl.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServerImpl.java
index 9e22d99..5144d56 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServerImpl.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServerImpl.java
@@ -78,7 +78,13 @@ import static
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRes
import static
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpResponseStatus.OK;
import static
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
-/** Implemenation of {@link MesosArtifactServer}. */
+/**
+ * Implemenation of {@link MesosArtifactServer}.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosArtifactServerImpl implements MesosArtifactServer {
private static final Logger LOG =
LoggerFactory.getLogger(MesosArtifactServerImpl.class);
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosConfiguration.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosConfiguration.java
index 2c5bf79..baa7e53 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosConfiguration.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosConfiguration.java
@@ -29,7 +29,13 @@ import scala.Option;
import static org.apache.flink.util.Preconditions.checkNotNull;
-/** The typed configuration settings associated with a Mesos scheduler. */
+/**
+ * The typed configuration settings associated with a Mesos scheduler.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosConfiguration {
private final String masterUrl;
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosResourceAllocation.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosResourceAllocation.java
index 47923e8..25cf16a 100644
---
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosResourceAllocation.java
+++
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosResourceAllocation.java
@@ -52,7 +52,11 @@ import static
org.apache.flink.util.Preconditions.checkNotNull;
* protocol definition.
*
* <p>This class is not thread-safe.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
*/
+@Deprecated
public class MesosResourceAllocation {
protected static final Logger LOG =
LoggerFactory.getLogger(MesosResourceAllocation.class);
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java
b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java
index c3ffd2c..7725f54 100755
--- a/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java
+++ b/flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java
@@ -48,7 +48,13 @@ import java.util.concurrent.TimeUnit;
import scala.concurrent.duration.Duration;
import scala.concurrent.duration.FiniteDuration;
-/** Utils for Mesos. */
+/**
+ * Utils for Mesos.
+ *
+ * @deprecated Apache Mesos support was deprecated in Flink 1.13 and is
subject to removal in the
+ * future (see FLINK-22352 for further details).
+ */
+@Deprecated
public class MesosUtils {
/**
