This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6f05e6fdadd5cd8f27983bc8140d05f1c3557bb6 Author: Matthias Pohl <[email protected]> AuthorDate: Fri Nov 26 12:32:27 2021 +0100 [FLINK-25080][tests] Move tests to flink-core --- .../java/org/apache/flink/util}/concurrent/ConjunctFutureTest.java | 3 +-- .../util}/concurrent/ExponentialBackoffRetryStrategyTest.java | 4 +--- .../org/apache/flink/util}/concurrent/FixedRetryStrategyTest.java | 4 +--- .../java/org/apache/flink/util}/concurrent/FutureUtilsTest.java | 7 +------ 4 files changed, 4 insertions(+), 14 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ConjunctFutureTest.java b/flink-core/src/test/java/org/apache/flink/util/concurrent/ConjunctFutureTest.java similarity index 99% rename from flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ConjunctFutureTest.java rename to flink-core/src/test/java/org/apache/flink/util/concurrent/ConjunctFutureTest.java index dd62300..2cdbbc8 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ConjunctFutureTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/concurrent/ConjunctFutureTest.java @@ -16,11 +16,10 @@ * limitations under the License. */ -package org.apache.flink.runtime.concurrent; +package org.apache.flink.util.concurrent; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.util.TestLogger; -import org.apache.flink.util.concurrent.FutureUtils; import org.apache.flink.util.concurrent.FutureUtils.ConjunctFuture; import org.junit.Test; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ExponentialBackoffRetryStrategyTest.java b/flink-core/src/test/java/org/apache/flink/util/concurrent/ExponentialBackoffRetryStrategyTest.java similarity index 94% rename from flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ExponentialBackoffRetryStrategyTest.java rename to flink-core/src/test/java/org/apache/flink/util/concurrent/ExponentialBackoffRetryStrategyTest.java index e794050..8953322 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ExponentialBackoffRetryStrategyTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/concurrent/ExponentialBackoffRetryStrategyTest.java @@ -16,11 +16,9 @@ * limitations under the License. */ -package org.apache.flink.runtime.concurrent; +package org.apache.flink.util.concurrent; import org.apache.flink.util.TestLogger; -import org.apache.flink.util.concurrent.ExponentialBackoffRetryStrategy; -import org.apache.flink.util.concurrent.RetryStrategy; import org.junit.Test; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FixedRetryStrategyTest.java b/flink-core/src/test/java/org/apache/flink/util/concurrent/FixedRetryStrategyTest.java similarity index 92% rename from flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FixedRetryStrategyTest.java rename to flink-core/src/test/java/org/apache/flink/util/concurrent/FixedRetryStrategyTest.java index 5386daa..e3b9a75 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FixedRetryStrategyTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/concurrent/FixedRetryStrategyTest.java @@ -16,11 +16,9 @@ * limitations under the License. */ -package org.apache.flink.runtime.concurrent; +package org.apache.flink.util.concurrent; import org.apache.flink.util.TestLogger; -import org.apache.flink.util.concurrent.FixedRetryStrategy; -import org.apache.flink.util.concurrent.RetryStrategy; import org.junit.Test; diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java b/flink-core/src/test/java/org/apache/flink/util/concurrent/FutureUtilsTest.java similarity index 99% rename from flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java rename to flink-core/src/test/java/org/apache/flink/util/concurrent/FutureUtilsTest.java index 14dbd28..4c2641f 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java +++ b/flink-core/src/test/java/org/apache/flink/util/concurrent/FutureUtilsTest.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.runtime.concurrent; +package org.apache.flink.util.concurrent; import org.apache.flink.api.common.time.Time; import org.apache.flink.core.testutils.FlinkMatchers; @@ -27,11 +27,6 @@ import org.apache.flink.util.ExceptionUtils; import org.apache.flink.util.FlinkException; import org.apache.flink.util.FlinkRuntimeException; import org.apache.flink.util.TestLogger; -import org.apache.flink.util.concurrent.ExponentialBackoffRetryStrategy; -import org.apache.flink.util.concurrent.FixedRetryStrategy; -import org.apache.flink.util.concurrent.FutureUtils; -import org.apache.flink.util.concurrent.ManuallyTriggeredScheduledExecutor; -import org.apache.flink.util.concurrent.ScheduledExecutorServiceAdapter; import org.junit.Assert; import org.junit.ClassRule;
