This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 610572e5a32c21ab89e856863b09e49657ac2e66 Author: Alexander Fedulov <1492164+afedu...@users.noreply.github.com> AuthorDate: Wed Jul 6 20:38:26 2022 +0200 [FLINK-28409][tests] Move FlinkContainerTestEnvironment and dependendencies into flink-connector-test-utils --- .../tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java index d2f9ab4..a4141b0 100644 --- a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java +++ b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java @@ -22,8 +22,8 @@ import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.JobManagerOptions; import org.apache.flink.configuration.MemorySize; import org.apache.flink.configuration.TaskManagerOptions; +import org.apache.flink.connector.testframe.container.FlinkContainerTestEnvironment; import org.apache.flink.tests.util.TestUtils; -import org.apache.flink.tests.util.flink.container.FlinkContainerTestEnvironment; /** A Flink Container which would bundles pulsar connector in its classpath. */ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvironment {