[FLINK-10540] Remove legacy FlinkMiniCluster and sub classes

docs/dev/libs/ml/contribution_guide.md

@@ -55,7 +55,7 @@ The rest are considered unit tests and should only test behavior which is local
 
 An integration test is a test which requires the full Flink system to be started.
 In order to do that properly, all integration test cases have to mix in the trait `FlinkTestBase`.
-This trait will set the right `ExecutionEnvironment` so that the test will be executed on a special `FlinkMiniCluster` designated for testing purposes.
+This trait will set the right `ExecutionEnvironment` so that the test will be executed on Flink's `MiniCluster`.
 Thus, an integration test could look the following:
 
 {% highlight scala %}

flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java

@@ -98,7 +98,7 @@ public abstract class FileInputFormat<OT> extends RichInputFormat<OT, FileInputS
 
 	/**
 	 * Initialize defaults for input format. Needs to be a static method because it is configured for local
-	 * cluster execution, see LocalFlinkMiniCluster.
+	 * cluster execution.
 	 * @param configuration The configuration to load defaults from
 	 */
 	private static void initDefaultsFromConfiguration(Configuration configuration) {

flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java

@@ -69,7 +69,7 @@ public static enum OutputDirectoryMode {
 
 	/**
 	 * Initialize defaults for output format. Needs to be a static method because it is configured for local
-	 * cluster execution, see LocalFlinkMiniCluster.
+	 * cluster execution.
 	 * @param configuration The configuration to load defaults from
 	 */
 	public static void initDefaultsFromConfiguration(Configuration configuration) {

flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/util/FlinkTestBase.scala

@@ -22,11 +22,11 @@ import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration
 import org.apache.flink.test.util.MiniClusterWithClientResource
 import org.scalatest.{BeforeAndAfter, Suite}
 
-/** Mixin to start and stop a LocalFlinkMiniCluster automatically for Scala based tests.
+/** Mixin to start and stop a MiniCluster automatically for Scala based tests.
   * Additionally a TestEnvironment with the started cluster is created and set as the default
   * [[org.apache.flink.api.java.ExecutionEnvironment]].
   *
-  * This mixin starts a LocalFlinkMiniCluster with one TaskManager and a number of slots given
+  * This mixin starts a MiniCluster with one TaskManager and a number of slots given
   * by parallelism. This value can be overridden in a sub class in order to start the cluster
   * with a different number of slots.
   *
@@ -38,7 +38,7 @@ import org.scalatest.{BeforeAndAfter, Suite}
   * @example
   *          {{{
   *            def testSomething: Unit = {
-  *             // Obtain TestEnvironment with started LocalFlinkMiniCluster
+  *             // Obtain TestEnvironment with started MiniCluster
   *             val env = ExecutionEnvironment.getExecutionEnvironment
   *
   *             env.fromCollection(...)

flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java

@@ -242,7 +242,7 @@ public boolean isRunning() {
 	 */
 	public void start() throws Exception {
 		synchronized (lock) {
-			checkState(!running, "FlinkMiniCluster is already running");
+			checkState(!running, "MiniCluster is already running");
 
 			LOG.info("Starting Flink Mini Cluster");
 			LOG.debug("Using configuration {}", miniClusterConfiguration);