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-rabbitmq.git
commit 650e8fceaab6ffcaa53f8fd83a61f4b4dcc39122 Author: Martijn Visser <[email protected]> AuthorDate: Mon Apr 3 13:44:59 2023 +0200 [FLINK-31701][Connector/RabbitMQ] Include local `DockerImageVersions` instead of relying on the one from the Flink repository --- .../connectors/rabbitmq/RMQSourceITCase.java | 2 +- .../rabbitmq/test/DockerImageVersions.java | 28 ++++++++++++++++++++++ 2 files changed, 29 insertions(+), 1 deletion(-) diff --git a/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java index 402d659..a245d54 100644 --- a/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java +++ b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java @@ -34,8 +34,8 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.sink.DiscardingSink; import org.apache.flink.streaming.api.functions.sink.SinkFunction; import org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig; +import org.apache.flink.streaming.connectors.rabbitmq.test.DockerImageVersions; import org.apache.flink.test.util.MiniClusterWithClientResource; -import org.apache.flink.util.DockerImageVersions; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Channel; diff --git a/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/test/DockerImageVersions.java b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/test/DockerImageVersions.java new file mode 100644 index 0000000..4c365ba --- /dev/null +++ b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/test/DockerImageVersions.java @@ -0,0 +1,28 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.streaming.connectors.rabbitmq.test; + +/** + * Utility class for defining the image names and versions of Docker containers used during the Java + * tests. The names/versions are centralised here in order to make testing version updates easier, + * as well as to provide a central file to use as a key when caching testing Docker files. + */ +public class DockerImageVersions { + + public static final String RABBITMQ = "rabbitmq:3.9.8-management-alpine"; +}
