dawidwys closed pull request #7369: [hotfix][docs] Fix typo teh in whole project
URL: https://github.com/apache/flink/pull/7369
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
index 3b3132b3d11..16b2adfd196 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
+++ b/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.
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
index ec2b542aa76..08b33334653 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
+++
b/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.
diff --git a/flink-dist/src/main/resources/flink-conf.yaml
b/flink-dist/src/main/resources/flink-conf.yaml
index efdf33e3852..25d4435452c 100644
--- a/flink-dist/src/main/resources/flink-conf.yaml
+++ b/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
diff --git
a/flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java
b/flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java
index bdc0c6749f6..d4c619d2ad1 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java
@@ -56,7 +56,7 @@
* 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) {
diff --git
a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java
b/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java
index cff8f1859c6..fbba03b2a25 100644
---
a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java
+++
b/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java
@@ -1148,7 +1148,7 @@ public String toString() {
/**
* 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.
*/
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java
index ea96d7d43d2..114d2811ef9 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java
+++
b/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
diff --git
a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
index 24448c7db0c..b8c2cdce29d 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
+++ b/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 = {
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
index a9bd1f694a3..f51ab313871 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
+++
b/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
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferSpiller.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferSpiller.java
index ae95408af44..700043092df 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferSpiller.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferSpiller.java
@@ -94,7 +94,7 @@
/**
* 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.
*/
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamRecordWriter.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamRecordWriter.java
index 3f174b05d4a..acda4898394 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamRecordWriter.java
+++
b/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";
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
