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
The following commit(s) were added to refs/heads/main by this push:
new 33d125f [FLINK-34020] Bump CI flink version on
flink-connector-rabbitmq. This closes #22
33d125f is described below
commit 33d125f591cc5f99e12280fbe2725bd374f7738b
Author: Martijn Visser <[email protected]>
AuthorDate: Fri Jan 12 09:35:00 2024 +0100
[FLINK-34020] Bump CI flink version on flink-connector-rabbitmq. This
closes #22
* [FLINK-34020] Bump CI flink version on flink-connector-rabbitmq
* [hotfix] Set lowest supported Flink version to 1.16.0 since that's still
supported
* [hotfix] Set copyright year to 2024
---------
Co-authored-by: Hang Ruan <[email protected]>
Co-authored-by: Sergey Nuyanzin <[email protected]>
---
.github/workflows/push_pr.yml | 12 ++++-
.github/workflows/weekly.yml | 11 +++-
NOTICE | 2 +-
flink-connector-rabbitmq/pom.xml | 30 +++++++++++
.../streaming/connectors/rabbitmq/RMQSource.java | 4 ++
.../rabbitmq/test/DockerImageVersions.java | 2 +-
pom.xml | 61 +++++++++++++++++-----
7 files changed, 104 insertions(+), 18 deletions(-)
diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index e84ea7d..6404e34 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -23,6 +23,16 @@ concurrency:
cancel-in-progress: true
jobs:
compile_and_test:
+ strategy:
+ matrix:
+ flink: [ 1.16-SNAPSHOT, 1.17-SNAPSHOT ]
+ jdk: [ '8, 11' ]
+ include:
+ - flink: 1.18-SNAPSHOT
+ jdk: '8, 11, 17'
+ - flink: 1.19-SNAPSHOT
+ jdk: '8, 11, 17, 21'
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
- flink_version: 1.17.0
\ No newline at end of file
+ flink_version: ${{ matrix.flink }}
+ jdk_version: ${{ matrix.jdk }}
\ No newline at end of file
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index c62cb13..cf31d3e 100644
--- a/.github/workflows/weekly.yml
+++ b/.github/workflows/weekly.yml
@@ -34,6 +34,11 @@ jobs:
branch: main
}, {
flink: 1.18-SNAPSHOT,
+ jdk: '8, 11, 17',
+ branch: main
+ }, {
+ flink: 1.19-SNAPSHOT,
+ jdk: '8, 11, 17, 21',
branch: main
}, {
flink: 1.16.2,
@@ -42,11 +47,13 @@ jobs:
flink: 1.17.1,
branch: v3.0
}, {
- flink: 1.18-SNAPSHOT,
+ flink: 1.18.0,
+ jdk: '8, 11, 17',
branch: v3.0
}]
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
flink_version: ${{ matrix.flink_branches.flink }}
connector_branch: ${{ matrix.flink_branches.branch }}
- run_dependency_convergence: false
+ jdk_version: ${{ matrix.flink_branches.jdk || '8, 11' }}
+ run_dependency_convergence: false
\ No newline at end of file
diff --git a/NOTICE b/NOTICE
index cbd559e..b3d91aa 100644
--- a/NOTICE
+++ b/NOTICE
@@ -1,5 +1,5 @@
Apache Flink RabbitMQ Connector
-Copyright 2014-2023 The Apache Software Foundation
+Copyright 2014-2024 The Apache Software Foundation
This product includes software developed at
The Apache Software Foundation (http://www.apache.org/).
diff --git a/flink-connector-rabbitmq/pom.xml b/flink-connector-rabbitmq/pom.xml
index a8fa213..fc6d527 100644
--- a/flink-connector-rabbitmq/pom.xml
+++ b/flink-connector-rabbitmq/pom.xml
@@ -91,4 +91,34 @@ under the License.
</dependency>
</dependencies>
+ <profiles>
+ <profile>
+ <id>run-end-to-end-tests</id>
+ <build>
+ <plugins>
+ <plugin>
+
<groupId>org.apache.maven.plugins</groupId>
+
<artifactId>maven-surefire-plugin</artifactId>
+ <executions>
+ <execution>
+
<id>end-to-end-tests</id>
+
<phase>integration-test</phase>
+ <goals>
+
<goal>test</goal>
+ </goals>
+ <configuration>
+
<includes>
+
<include>**/*.*</include>
+
</includes>
+
<systemPropertyVariables>
+
<moduleDir>${project.basedir}</moduleDir>
+
</systemPropertyVariables>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
</project>
diff --git
a/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
b/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
index 017bc7c..63fa875 100644
---
a/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
+++
b/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
@@ -42,6 +42,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
+import java.util.ArrayDeque;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -236,6 +238,8 @@ public class RMQSource<OUT> extends
MultipleIdsMessageAcknowledgingSourceBase<OU
@Override
public void open(Configuration config) throws Exception {
super.open(config);
+ sessionIds = new ArrayList<>(64);
+ sessionIdsPerSnapshot = new ArrayDeque<>();
try {
connection = setupConnection();
channel = setupChannel(connection);
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
index 4c365ba..9440bb9 100644
---
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
@@ -24,5 +24,5 @@ package org.apache.flink.streaming.connectors.rabbitmq.test;
*/
public class DockerImageVersions {
- public static final String RABBITMQ = "rabbitmq:3.9.8-management-alpine";
+ public static final String RABBITMQ = "rabbitmq:3.12.12-management-alpine";
}
diff --git a/pom.xml b/pom.xml
index afb65b4..211db42 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,11 +48,11 @@ under the License.
</modules>
<properties>
- <flink.version>1.17.0</flink.version>
+ <flink.version>1.16.0</flink.version>
- <junit5.version>5.9.1</junit5.version>
+ <junit5.version>5.10.1</junit5.version>
<assertj.version>3.23.1</assertj.version>
- <testcontainers.version>1.17.2</testcontainers.version>
+ <testcontainers.version>1.19.3</testcontainers.version>
<mockito.version>3.4.6</mockito.version>
<hamcrest.version>1.3</hamcrest.version>
@@ -84,10 +84,11 @@ under the License.
<!-- Test dependencies -->
<dependency>
- <groupId>org.junit.jupiter</groupId>
- <artifactId>junit-jupiter</artifactId>
+ <groupId>org.junit</groupId>
+ <artifactId>junit-bom</artifactId>
<version>${junit5.version}</version>
- <scope>test</scope>
+ <type>pom</type>
+ <scope>import</scope>
</dependency>
<dependency>
@@ -256,25 +257,32 @@ under the License.
<!-- For dependency convergence -->
<dependency>
- <groupId>org.junit.platform</groupId>
- <artifactId>junit-platform-engine</artifactId>
- <version>1.9.1</version>
+ <groupId>org.junit.vintage</groupId>
+ <artifactId>junit-vintage-engine</artifactId>
+ <version>${junit5.version}</version>
</dependency>
<!-- For dependency convergence -->
<dependency>
- <groupId>com.esotericsoftware.kryo</groupId>
- <artifactId>kryo</artifactId>
- <version>2.24.0</version>
+ <groupId>org.junit.platform</groupId>
+ <artifactId>junit-platform-engine</artifactId>
+ <version>1.10.1</version>
</dependency>
<!-- For dependency convergence -->
<dependency>
<groupId>org.junit.jupiter</groupId>
- <artifactId>junit-jupiter-api</artifactId>
+ <artifactId>junit-jupiter</artifactId>
<version>${junit5.version}</version>
</dependency>
+ <!-- For dependency convergence -->
+ <dependency>
+ <groupId>com.esotericsoftware.kryo</groupId>
+ <artifactId>kryo</artifactId>
+ <version>2.24.0</version>
+ </dependency>
+
<!-- For dependency convergence -->
<dependency>
<groupId>net.bytebuddy</groupId>
@@ -289,6 +297,33 @@ under the License.
<version>2.6</version>
</dependency>
+ <!-- For dependency convergence -->
+ <dependency>
+ <groupId>org.objenesis</groupId>
+ <artifactId>objenesis</artifactId>
+ <version>2.6</version>
+ </dependency>
+
+ <!-- For dependency convergence -->
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-compress</artifactId>
+ <version>1.24.0</version>
+ </dependency>
+
+ <!-- For dependency convergence -->
+ <dependency>
+ <groupId>org.xerial.snappy</groupId>
+ <artifactId>snappy-java</artifactId>
+ <version>1.1.10.4</version>
+ </dependency>
+ <!-- For dependency convergence -->
+ <dependency>
+ <groupId>org.junit.jupiter</groupId>
+ <artifactId>junit-jupiter-api</artifactId>
+ <version>${junit5.version}</version>
+ </dependency>
+
</dependencies>
</dependencyManagement>
