This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit f333cf2d5a0bf0a5dfe0421df4c391dd84a22afa Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Wed Sep 14 17:12:10 2022 +0200 [FLINK-29285][tests] Move TestUtils#getResource --- .../tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 a4141b0..9f34554 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 @@ -23,7 +23,7 @@ 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.test.resources.ResourceTestUtils; /** A Flink Container which would bundles pulsar connector in its classpath. */ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvironment { @@ -47,7 +47,7 @@ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvir } private static String resourcePath(String jarName) { - return TestUtils.getResource(jarName).toAbsolutePath().toString(); + return ResourceTestUtils.getResource(jarName).toAbsolutePath().toString(); } protected static Configuration flinkConfiguration() {