You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2023/02/02 09:11:58 UTC
[flink] 03/05: [hotfix] Fix typo of InputGateSpecUtils.
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 439a4f7fc81ba4336bd164a60483137de0b35cc0
Author: Weijie Guo <re...@163.com>
AuthorDate: Tue Jan 17 11:51:55 2023 +0800
[hotfix] Fix typo of InputGateSpecUtils.
---
.../{InputGateSpecUitls.java => InputGateSpecUtils.java} | 2 +-
.../network/partition/consumer/SingleInputGateFactory.java | 2 +-
.../org/apache/flink/runtime/shuffle/NettyShuffleUtils.java | 2 +-
.../io/network/partition/consumer/GateBuffersSpecTest.java | 12 ++++++------
.../io/network/partition/consumer/SingleInputGateTest.java | 4 ++--
5 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUitls.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUtils.java
similarity index 99%
rename from flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUitls.java
rename to flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUtils.java
index 55fe71d9234..6a7085ce84a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUitls.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateSpecUtils.java
@@ -27,7 +27,7 @@ import static org.apache.flink.util.Preconditions.checkArgument;
import static org.apache.flink.util.Preconditions.checkState;
/** Utils to manage the specs of the {@link InputGate}, for example, {@link GateBuffersSpec}. */
-public class InputGateSpecUitls {
+public class InputGateSpecUtils {
public static final int DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH = 1000;
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java
index 04378c99a40..98a5d8e04bb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java
@@ -56,7 +56,7 @@ import javax.annotation.Nonnull;
import java.io.IOException;
import java.util.Optional;
-import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUitls.createGateBuffersSpec;
+import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUtils.createGateBuffersSpec;
import static org.apache.flink.runtime.shuffle.ShuffleUtils.applyWithShuffleTypeCheck;
/** Factory for {@link SingleInputGate} to use in {@link NettyShuffleEnvironment}. */
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleUtils.java
index 947f0a976a5..0c78cb38dfb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleUtils.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleUtils.java
@@ -28,7 +28,7 @@ import org.apache.commons.lang3.tuple.Pair;
import java.util.Map;
import java.util.Optional;
-import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUitls.createGateBuffersSpec;
+import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUtils.createGateBuffersSpec;
import static org.apache.flink.util.Preconditions.checkNotNull;
import static org.apache.flink.util.Preconditions.checkState;
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/GateBuffersSpecTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/GateBuffersSpecTest.java
index 8161d00c0d1..4ddd7cbb4ea 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/GateBuffersSpecTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/GateBuffersSpecTest.java
@@ -27,7 +27,7 @@ import org.junit.runners.Parameterized;
import java.util.Optional;
-import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUitls.getEffectiveMaxRequiredBuffersPerGate;
+import static org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUtils.getEffectiveMaxRequiredBuffersPerGate;
import static org.assertj.core.api.Assertions.assertThat;
/** Tests for {@link GateBuffersSpec}. */
@@ -146,8 +146,8 @@ class GateBuffersSpecTest {
getEffectiveMaxRequiredBuffersPerGate(partitionType, emptyConfig);
int expectEffectiveMaxRequiredBuffers =
isPipelineResultPartition(partitionType)
- ? InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM
- : InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH;
+ ? InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM
+ : InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH;
assertThat(effectiveMaxRequiredBuffers).isEqualTo(expectEffectiveMaxRequiredBuffers);
Optional<Integer> configuredMaxRequiredBuffers = Optional.of(100);
@@ -179,7 +179,7 @@ class GateBuffersSpecTest {
int numInputChannels,
ResultPartitionType partitionType,
int numExclusiveBuffersPerChannel) {
- return InputGateSpecUitls.createGateBuffersSpec(
+ return InputGateSpecUtils.createGateBuffersSpec(
getMaxRequiredBuffersPerGate(partitionType),
numExclusiveBuffersPerChannel,
8,
@@ -190,8 +190,8 @@ class GateBuffersSpecTest {
private static Optional<Integer> getMaxRequiredBuffersPerGate(
ResultPartitionType partitionType) {
return isPipelineResultPartition(partitionType)
- ? Optional.of(InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM)
- : Optional.of(InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH);
+ ? Optional.of(InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM)
+ : Optional.of(InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH);
}
private static boolean isPipelineResultPartition(ResultPartitionType partitionType) {
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
index e591d1e7951..2ae6025db09 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
@@ -1223,9 +1223,9 @@ public class SingleInputGateTest extends InputGateTestBase {
Optional<Integer> expectMaxRequiredBuffersPerGate =
isPipeline
? Optional.of(
- InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM)
+ InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM)
: Optional.of(
- InputGateSpecUitls.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH);
+ InputGateSpecUtils.DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH);
nettyShuffleEnvironmentBuilder.setMaxRequiredBuffersPerGate(
expectMaxRequiredBuffersPerGate);
NettyShuffleEnvironment netEnv = nettyShuffleEnvironmentBuilder.build();