[hotfix][docs] Fix incorrectly spelled "the" as "teh"

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

@@ -554,7 +554,7 @@ public void enableGenericTypes() {
 	 * is used, Flink will throw an {@code UnsupportedOperationException} whenever it encounters
 	 * a data type that would go through Kryo for serialization.
 	 *
-	 * <p>Disabling generic types can be helpful to eagerly find and eliminate teh use of types
+	 * <p>Disabling generic types can be helpful to eagerly find and eliminate the use of types
 	 * that would go through Kryo serialization during runtime. Rather than checking types
 	 * individually, using this option will throw exceptions eagerly in the places where generic
 	 * types are used.

flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java

@@ -32,7 +32,7 @@
 
 /**
  * A serializer for {@link List Lists}. The serializer relies on an element serializer
- * for teh serialization of the list's elements.
+ * for the serialization of the list's elements.
  *
  * <p>The serialization format for the list is as follows: four bytes for the length of the lost,
  * followed by the serialized representation of each element.

flink-dist/src/main/resources/flink-conf.yaml

@@ -181,7 +181,7 @@ rest.port: 8081
 
 # The amount of memory going to the network stack. These numbers usually need 
 # no tuning. Adjusting them may be necessary in case of an "Insufficient number
-# of network buffers" error. The default min is 64MB, teh default max is 1GB.
+# of network buffers" error. The default min is 64MB, the default max is 1GB.
 # 
 # taskmanager.network.memory.fraction: 0.1
 # taskmanager.network.memory.min: 64mb

flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java

@@ -56,7 +56,7 @@ public class ClosureCleaner {
 	 *                                 not serializable after the closure cleaning.
 	 *
 	 * @throws RuntimeException A RuntimeException may be thrown, if the code of the class could not
-	 *                          be loaded, in order to process during teh closure cleaning.
+	 *                          be loaded, in order to process during the closure cleaning.
 	 */
 	public static void clean(Object func, boolean checkSerializable) {
 		if (func == null) {

flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java

@@ -1148,7 +1148,7 @@ public static final class UnclosedBranchDescriptor {
 		/**
 		 * Creates a new branching descriptor.
 		 *
-		 * @param branchingNode The node where the branch occurred (teh node with multiple outputs).
+		 * @param branchingNode The node where the branch occurred (the node with multiple outputs).
 		 * @param joinedPathsVector A bit vector describing which branches are tracked by this descriptor.
 		 *                          The bit vector is one, where the branch is tracked, zero otherwise.
 		 */

flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java

@@ -44,7 +44,7 @@
 
 /**
  * An implementation of the {@link HighAvailabilityServices} using Apache ZooKeeper.
- * The services store data in ZooKeeper's nodes as illustrated by teh following tree structure:
+ * The services store data in ZooKeeper's nodes as illustrated by the following tree structure:
  * 
  * <pre>
  * /flink

flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala

@@ -841,7 +841,7 @@ object AkkaUtils {
     *
     * @param akkaURL The URL to extract the host and port from.
     * @throws java.lang.Exception Thrown, if the given string does not represent a proper url
-    * @return The InetSocketAddress with teh extracted host and port.
+    * @return The InetSocketAddress with the extracted host and port.
     */
   @throws(classOf[Exception])
   def getInetSocketAddressFromAkkaURL(akkaURL: String): InetSocketAddress = {

flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java

@@ -1951,7 +1951,7 @@ public void testListStateMerging() throws Exception {
 
 			// populate the different namespaces
 			//  - abc spreads the values over three namespaces
-			//  - def spreads teh values over two namespaces (one empty)
+			//  - def spreads the values over two namespaces (one empty)
 			//  - ghi is empty
 			//  - jkl has all elements already in the target namespace
 			//  - mno has all elements already in one source namespace
@@ -2223,7 +2223,7 @@ public void testReducingStateMerging() throws Exception {
 
 			// populate the different namespaces
 			//  - abc spreads the values over three namespaces
-			//  - def spreads teh values over two namespaces (one empty)
+			//  - def spreads the values over two namespaces (one empty)
 			//  - ghi is empty
 			//  - jkl has all elements already in the target namespace
 			//  - mno has all elements already in one source namespace
@@ -2396,7 +2396,7 @@ public void testAggregatingStateMergingWithMutableAccumulator() throws Exception
 
 			// populate the different namespaces
 			//  - abc spreads the values over three namespaces
-			//  - def spreads teh values over two namespaces (one empty)
+			//  - def spreads the values over two namespaces (one empty)
 			//  - ghi is empty
 			//  - jkl has all elements already in the target namespace
 			//  - mno has all elements already in one source namespace
@@ -2569,7 +2569,7 @@ public void testAggregatingStateMergingWithImmutableAccumulator() throws Excepti
 
 			// populate the different namespaces
 			//  - abc spreads the values over three namespaces
-			//  - def spreads teh values over two namespaces (one empty)
+			//  - def spreads the values over two namespaces (one empty)
 			//  - ghi is empty
 			//  - jkl has all elements already in the target namespace
 			//  - mno has all elements already in one source namespace

flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferSpiller.java

@@ -94,7 +94,7 @@ public class BufferSpiller implements BufferBlocker {
 	/**
 	 * Creates a new buffer spiller, spilling to one of the I/O manager's temp directories.
 	 *
-	 * @param ioManager The I/O manager for access to teh temp directories.
+	 * @param ioManager The I/O manager for access to the temp directories.
 	 * @param pageSize The page size used to re-create spilled buffers.
 	 * @throws IOException Thrown if the temp files for spilling cannot be initialized.
 	 */

flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamRecordWriter.java

@@ -36,7 +36,7 @@
 @Internal
 public class StreamRecordWriter<T extends IOReadableWritable> extends RecordWriter<T> {
 
-	/** Default name for teh output flush thread, if no name with a task reference is given. */
+	/** Default name for the output flush thread, if no name with a task reference is given. */
 	private static final String DEFAULT_OUTPUT_FLUSH_THREAD_NAME = "OutputFlusher";