[hotfix][docs] Fix typos This closes #5406.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5ffd5f8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5ffd5f8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b5ffd5f8 Branch: refs/heads/master Commit: b5ffd5f8a57d7bc09bb7cbfbeb4a0a56eab53ff6 Parents: 97f0cac Author: zhouhai02 <[email protected]> Authored: Sat Feb 3 14:08:29 2018 +0800 Committer: zentol <[email protected]> Committed: Tue Feb 6 20:20:47 2018 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/client/cli/CliFrontend.java | 2 +- .../org/apache/flink/api/common/functions/CoGroupFunction.java | 2 +- .../org/apache/flink/api/common/io/DelimitedInputFormat.java | 6 +++--- .../scala/org/apache/flink/table/plan/util/CorrelateUtil.scala | 2 +- .../rest/messages/queue/AsynchronouslyCreatedResource.java | 2 +- 5 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b5ffd5f8/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java index 628e9e4..560bc6f 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java +++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java @@ -886,7 +886,7 @@ public class CliFrontend { * Internal interface to encapsulate cluster actions which are executed via * the {@link ClusterClient}. * - * @param <T> tyoe pf the cluster id + * @param <T> type of the cluster id */ @FunctionalInterface private interface ClusterAction<T> { http://git-wip-us.apache.org/repos/asf/flink/blob/b5ffd5f8/flink-core/src/main/java/org/apache/flink/api/common/functions/CoGroupFunction.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/functions/CoGroupFunction.java b/flink-core/src/main/java/org/apache/flink/api/common/functions/CoGroupFunction.java index db40370..cf2fdc5 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/functions/CoGroupFunction.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/functions/CoGroupFunction.java @@ -28,7 +28,7 @@ import org.apache.flink.util.Collector; * after a key and then "joining" the groups by calling this function with the two sets for each key. * If a key is present in only one of the two inputs, it may be that one of the groups is empty. * <p> - * The basic syntax for using CoGoup on two data sets is as follows: + * The basic syntax for using CoGroup on two data sets is as follows: * <pre>{@code * DataSet<X> set1 = ...; * DataSet<Y> set2 = ...; http://git-wip-us.apache.org/repos/asf/flink/blob/b5ffd5f8/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java index 04b04b8..d6397e6 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java @@ -116,8 +116,8 @@ public abstract class DelimitedInputFormat<OT> extends FileInputFormat<OT> imple DEFAULT_MAX_NUM_SAMPLES = maxSamples; if (minSamples > maxSamples) { - LOG.error("Defaul minimum number of line samples cannot be greater the default maximum number " + - "of line samples: min=" + minSamples + ", max=" + maxSamples + ". Defaulting minumum to maximum."); + LOG.error("Default minimum number of line samples cannot be greater the default maximum number " + + "of line samples: min=" + minSamples + ", max=" + maxSamples + ". Defaulting minimum to maximum."); DEFAULT_MIN_NUM_SAMPLES = maxSamples; } else { DEFAULT_MIN_NUM_SAMPLES = minSamples; @@ -127,7 +127,7 @@ public abstract class DelimitedInputFormat<OT> extends FileInputFormat<OT> imple ConfigConstants.DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN); if (maxLen <= 0) { maxLen = ConfigConstants.DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN; - LOG.error("Invalid value for the maximum sample record length. Using defailt value of " + maxLen + '.'); + LOG.error("Invalid value for the maximum sample record length. Using default value of " + maxLen + '.'); } else if (maxLen < DEFAULT_READ_BUFFER_SIZE) { maxLen = DEFAULT_READ_BUFFER_SIZE; LOG.warn("Increasing maximum sample record length to size of the read buffer (" + maxLen + ")."); http://git-wip-us.apache.org/repos/asf/flink/blob/b5ffd5f8/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/CorrelateUtil.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/CorrelateUtil.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/CorrelateUtil.scala index a74fa35..1db20a1 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/CorrelateUtil.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/CorrelateUtil.scala @@ -22,7 +22,7 @@ import org.apache.calcite.rex.{RexProgram, RexProgramBuilder} import org.apache.flink.table.plan.nodes.logical.{FlinkLogicalCalc, FlinkLogicalTableFunctionScan} /** - * A utility for datasteam and dataset correlate rules. + * A utility for datastream and dataset correlate rules. */ object CorrelateUtil { http://git-wip-us.apache.org/repos/asf/flink/blob/b5ffd5f8/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/AsynchronouslyCreatedResource.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/AsynchronouslyCreatedResource.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/AsynchronouslyCreatedResource.java index 6eb1ba6..6aa9f89 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/AsynchronouslyCreatedResource.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/AsynchronouslyCreatedResource.java @@ -29,7 +29,7 @@ import javax.annotation.Nullable; public interface AsynchronouslyCreatedResource<T> extends ResponseBody { /** - * Retuns the status of the resource creation. + * Returns the status of the resource creation. */ QueueStatus queueStatus();
