[FLINK-10922] Remove Scala Kafka010Example from flink-end-to-end-tests

This commit removes the Scala based Kafka010Example from flink-end-to-end-tests/
flink-streaming-kafka010-test module. Moreover, it adds relative paths to their
parent pom's and cleans up the flink-streaming-kafka*/pom.xml.

flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml

@@ -24,6 +24,7 @@ under the License.
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
 		<version>1.8-SNAPSHOT</version>
+		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 

flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml

@@ -24,6 +24,7 @@ under the License.
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
 		<version>1.8-SNAPSHOT</version>
+		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
@@ -48,12 +49,6 @@ under the License.
 			<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
 			<version>${project.version}</version>
 		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-java</artifactId>
-			<version>${project.version}</version>
-		</dependency>
 	</dependencies>
 
 	<build>

flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml

@@ -24,6 +24,7 @@ under the License.
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
 		<version>1.8-SNAPSHOT</version>
+		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
@@ -48,60 +49,10 @@ under the License.
 			<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
 			<version>${project.version}</version>
 		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-streaming-scala_${scala.binary.version}</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-java</artifactId>
-			<version>${project.version}</version>
-		</dependency>
 	</dependencies>
 
 	<build>
 		<plugins>
-
-			<!-- Scala Compiler -->
-			<plugin>
-				<groupId>net.alchim31.maven</groupId>
-				<artifactId>scala-maven-plugin</artifactId>
-				<executions>
-					<!-- Run scala compiler in the process-resources phase, so that dependencies on
-						scala classes can be resolved later in the (Java) compile phase -->
-					<execution>
-						<id>scala-compile-first</id>
-						<phase>process-resources</phase>
-						<goals>
-							<goal>add-source</goal>
-							<goal>compile</goal>
-						</goals>
-					</execution>
-
-					<!-- Run scala compiler in the process-test-resources phase, so that dependencies on
-						 scala classes can be resolved later in the (Java) test-compile phase -->
-					<execution>
-						<id>scala-test-compile</id>
-						<phase>process-test-resources</phase>
-						<goals>
-							<goal>testCompile</goal>
-						</goals>
-					</execution>
-				</executions>
-			</plugin>
-
-			<!-- Scala Code Style, most of the configuration done via plugin management -->
-			<plugin>
-				<groupId>org.scalastyle</groupId>
-				<artifactId>scalastyle-maven-plugin</artifactId>
-				<configuration>
-					<configLocation>${project.basedir}/../../tools/maven/scalastyle-config.xml</configLocation>
-				</configuration>
-			</plugin>
-
 			<!-- Use the shade plugin to build a fat jar for the kafka connector test -->
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>

flink-end-to-end-tests/flink-streaming-kafka010-test/src/main/scala/org/apache/flink/streaming/scala/kafka/test/Kafka010Example.scala

-/*
- * 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.streaming.scala.kafka.test
-
-import org.apache.flink.api.common.restartstrategy.RestartStrategies
-import org.apache.flink.api.common.serialization.SimpleStringSchema
-import org.apache.flink.api.java.utils.ParameterTool
-import org.apache.flink.streaming.api.scala._
-import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer010, FlinkKafkaProducer010}
-
-/**
- * An example that shows how to read from and write to Kafka. This will read String messages
- * from the input topic, prefix them by a configured prefix and output to the output topic.
- *
- * Please pass the following arguments to run the example:
- * {{{
- * --input-topic test-input
- * --output-topic test-output
- * --bootstrap.servers localhost:9092
- * --zookeeper.connect localhost:2181
- * --group.id myconsumer
- * }}}
- */
-object Kafka010Example {
-
-  def main(args: Array[String]): Unit = {
-
-    // parse input arguments
-    val params = ParameterTool.fromArgs(args)
-
-    if (params.getNumberOfParameters < 4) {
-      println("Missing parameters!\n"
-        + "Usage: Kafka --input-topic <topic> --output-topic <topic> "
-        + "--bootstrap.servers <kafka brokers> "
-        + "--zookeeper.connect <zk quorum> --group.id <some id> [--prefix <prefix>]")
-      return
-    }
-
-    val prefix = params.get("prefix", "PREFIX:")
-
-
-    val env = StreamExecutionEnvironment.getExecutionEnvironment
-    env.getConfig.disableSysoutLogging
-    env.getConfig.setRestartStrategy(RestartStrategies.fixedDelayRestart(4, 10000))
-    // create a checkpoint every 5 seconds
-    env.enableCheckpointing(5000)
-    // make parameters available in the web interface
-    env.getConfig.setGlobalJobParameters(params)
-
-    // create a Kafka streaming source consumer for Kafka 0.10.x
-    val kafkaConsumer = new FlinkKafkaConsumer010(
-      params.getRequired("input-topic"),
-      new SimpleStringSchema,
-      params.getProperties)
-
-    val messageStream = env
-      .addSource(kafkaConsumer)
-      .map(in => prefix + in)
-
-    // create a Kafka producer for Kafka 0.10.x
-    val kafkaProducer = new FlinkKafkaProducer010(
-      params.getRequired("output-topic"),
-      new SimpleStringSchema,
-      params.getProperties)
-
-    // write data into Kafka
-    messageStream.addSink(kafkaProducer)
-
-    env.execute("Kafka 0.10 Example")
-  }
-
-}

flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml

@@ -24,6 +24,7 @@ under the License.
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
 		<version>1.8-SNAPSHOT</version>
+		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
@@ -49,12 +50,6 @@ under the License.
 			<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
 			<version>${project.version}</version>
 		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-java</artifactId>
-			<version>${project.version}</version>
-		</dependency>
 	</dependencies>
 
 	<build>