This is an automated email from the ASF dual-hosted git repository.
ferenc-csaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-mongodb.git
The following commit(s) were added to refs/heads/main by this push:
new 7af8e48 [FLINK-40066] Update `flink-connector-parent` to 2.0.0 and
Flink to 2.1.2
7af8e48 is described below
commit 7af8e4817a2db54611fd223bfad752890de3304f
Author: Purushottam Sinha <[email protected]>
AuthorDate: Mon Jul 13 19:26:17 2026 +0530
[FLINK-40066] Update `flink-connector-parent` to 2.0.0 and Flink to 2.1.2
---
.github/workflows/push_pr.yml | 2 +-
.github/workflows/weekly.yml | 10 +++++-----
flink-connector-mongodb-table-tests/pom.xml | 17 +++++++++++++++++
.../acc4170e-bf83-4a8c-b46e-40ceccfeae1f | 9 +++++++++
.../archunit-violations/stored.rules | 11 ++++++-----
pom.xml | 6 +++---
tools/maven/checkstyle.xml | 8 +-------
7 files changed, 42 insertions(+), 21 deletions(-)
diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index 9215917..2b5a235 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -29,7 +29,7 @@ jobs:
strategy:
matrix:
mongodb: [ mongodb4, mongodb5, mongodb6, mongodb7 ]
- flink: [ 2.1-SNAPSHOT, 2.2-SNAPSHOT ]
+ flink: [ 2.1.2, 2.2.1 ]
jdk: [ '11','17', '21' ]
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index c057e3f..53b0a27 100644
--- a/.github/workflows/weekly.yml
+++ b/.github/workflows/weekly.yml
@@ -30,12 +30,12 @@ jobs:
strategy:
matrix:
flink_branches: [ {
- flink: 1.19-SNAPSHOT,
- jdk: '8, 11, 17, 21',
+ flink: 2.1-SNAPSHOT,
+ jdk: '11, 17, 21',
branch: main
}, {
- flink: 1.20-SNAPSHOT,
- jdk: '8, 11, 17, 21',
+ flink: 2.2-SNAPSHOT,
+ jdk: '11, 17, 21',
branch: main
},{
flink: 1.19.2,
@@ -44,7 +44,7 @@ jobs:
}, {
flink: 1.20.1,
jdk: '8, 11, 17, 21',
- branch: main
+ branch: v2.0
}]
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
diff --git a/flink-connector-mongodb-table-tests/pom.xml
b/flink-connector-mongodb-table-tests/pom.xml
index 6da604e..c9840b6 100644
--- a/flink-connector-mongodb-table-tests/pom.xml
+++ b/flink-connector-mongodb-table-tests/pom.xml
@@ -1,3 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+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.
+-->
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
diff --git
a/flink-connector-mongodb/archunit-violations/acc4170e-bf83-4a8c-b46e-40ceccfeae1f
b/flink-connector-mongodb/archunit-violations/acc4170e-bf83-4a8c-b46e-40ceccfeae1f
new file mode 100644
index 0000000..9d358e6
--- /dev/null
+++
b/flink-connector-mongodb/archunit-violations/acc4170e-bf83-4a8c-b46e-40ceccfeae1f
@@ -0,0 +1,9 @@
+Class <org.apache.flink.connector.mongodb.table.MongoFilterPushDownVisitor>
extends class <org.apache.flink.table.expressions.ExpressionDefaultVisitor> in
(MongoFilterPushDownVisitor.java:0)
+Constructor
<org.apache.flink.connector.mongodb.sink.MongoSink.<init>(org.apache.flink.connector.mongodb.common.config.MongoConnectionOptions,
org.apache.flink.connector.mongodb.sink.config.MongoWriteOptions,
org.apache.flink.connector.mongodb.sink.writer.serializer.MongoSerializationSchema)>
calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object,
org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in
(MongoSink.java:73)
+Constructor
<org.apache.flink.connector.mongodb.sink.writer.MongoWriter.<init>(org.apache.flink.connector.mongodb.common.config.MongoConnectionOptions,
org.apache.flink.connector.mongodb.sink.config.MongoWriteOptions, boolean,
org.apache.flink.api.connector.sink2.WriterInitContext,
org.apache.flink.connector.mongodb.sink.writer.serializer.MongoSerializationSchema)>
calls constructor
<org.apache.flink.api.common.functions.util.ListCollector.<init>(java.util.List)>
in (MongoWriter.java:109)
+Constructor
<org.apache.flink.connector.mongodb.table.MongoFilterPushDownVisitor.<init>()>
calls constructor
<org.apache.flink.table.expressions.ExpressionDefaultVisitor.<init>()> in
(MongoFilterPushDownVisitor.java:62)
+Constructor
<org.apache.flink.connector.mongodb.table.converter.RowDataToBsonConverters$13.<init>(int,
org.apache.flink.table.types.logical.RowType,
[Lorg.apache.flink.table.data.RowData$FieldGetter;,
[Lorg.apache.flink.util.function.SerializableFunction;)> has parameter of type
<[Lorg.apache.flink.table.data.RowData$FieldGetter;> in
(RowDataToBsonConverters.java:0)
+Field
<org.apache.flink.connector.mongodb.table.converter.RowDataToBsonConverters$13.val$fieldGetters>
has type <[Lorg.apache.flink.table.data.RowData$FieldGetter;> in
(RowDataToBsonConverters.java:0)
+Method
<org.apache.flink.connector.mongodb.sink.writer.MongoWriter.doBulkWrite()> is
annotated with <org.apache.flink.annotation.VisibleForTesting> in
(MongoWriter.java:0)
+Method
<org.apache.flink.connector.mongodb.source.enumerator.splitter.MongoSampleSplitter.createSplits(java.util.List,
int, com.mongodb.MongoNamespace)> is annotated with
<org.apache.flink.annotation.VisibleForTesting> in (MongoSampleSplitter.java:0)
+Method
<org.apache.flink.connector.mongodb.source.enumerator.splitter.MongoSampleSplitter.split(org.apache.flink.connector.mongodb.source.enumerator.splitter.MongoSplitContext,
java.util.function.BiFunction)> is annotated with
<org.apache.flink.annotation.VisibleForTesting> in (MongoSampleSplitter.java:0)
diff --git a/flink-connector-mongodb/archunit-violations/stored.rules
b/flink-connector-mongodb/archunit-violations/stored.rules
index 7c14c18..29d324b 100644
--- a/flink-connector-mongodb/archunit-violations/stored.rules
+++ b/flink-connector-mongodb/archunit-violations/stored.rules
@@ -1,10 +1,11 @@
#
-#Wed Nov 02 20:18:11 CST 2022
+#Sat Jul 04 00:35:22 IST 2026
+Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @Public\ must\ be\
annotated\ with\ @Public.=ed03507c-2a0e-4dc2-b0c6-b90a8469bb7c
+Connector\ production\ code\ must\ not\ depend\ on\ non-public\ API\ outside\
of\ connector\ packages=54355260-ce16-4e0e-9768-00cb07fadf7e
+ITCASE\ tests\ should\ use\ a\ MiniCluster\ resource\ or\
extension=0339fa9f-980e-4b71-a187-dde3c2e4d22d
Production\ code\ must\ not\ call\ methods\ annotated\ with\
@VisibleForTesting=f871efde-12fe-46a5-9b10-11382284683f
Options\ for\ connectors\ and\ formats\ should\ reside\ in\ a\ consistent\
package\ and\ be\ public\ API.=d5033bdc-beb6-4505-9fd1-ab50e6c4be20
Tests\ inheriting\ from\ AbstractTestBase\ should\ have\ name\ ending\ with\
ITCase=07a10766-610a-4f6d-9b7f-82d523e68bb6
-Classes\ in\ API\ packages\ should\ have\ at\ least\ one\ API\ visibility\
annotation.=ae2f06aa-8fb6-4585-a50c-ffe88f59697d
Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @PublicEvolving\
must\ be\ annotated\ with\
@Public(Evolving).=bf400375-9b08-442c-80c1-051333988494
-Return\ and\ argument\ types\ of\ methods\ annotated\ with\ @Public\ must\ be\
annotated\ with\ @Public.=ed03507c-2a0e-4dc2-b0c6-b90a8469bb7c
-ITCASE\ tests\ should\ use\ a\ MiniCluster\ resource\ or\
extension=0339fa9f-980e-4b71-a187-dde3c2e4d22d
-Connector\ production\ code\ must\ not\ depend\ on\ non-public\ API\ outside\
of\ connector\ packages=54355260-ce16-4e0e-9768-00cb07fadf7e
+Classes\ in\ API\ packages\ should\ have\ at\ least\ one\ API\ visibility\
annotation.=ae2f06aa-8fb6-4585-a50c-ffe88f59697d
+Connector\ production\ code\ must\ depend\ only\ on\ public\ API\ when\
outside\ of\ connector\ packages=acc4170e-bf83-4a8c-b46e-40ceccfeae1f
diff --git a/pom.xml b/pom.xml
index 4d62283..8134e79 100644
--- a/pom.xml
+++ b/pom.xml
@@ -24,7 +24,7 @@ under the License.
<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-parent</artifactId>
- <version>1.1.0</version>
+ <version>2.0.0</version>
</parent>
<artifactId>flink-connector-mongodb-parent</artifactId>
@@ -57,7 +57,7 @@ under the License.
<mongodb7.version>7.0.12</mongodb7.version>
<mongodb.version>${mongodb4.version}</mongodb.version>
- <flink.version>2.1.0</flink.version>
+ <flink.version>2.1.2</flink.version>
<scala.binary.version>2.12</scala.binary.version>
<scala-library.version>2.12.7</scala-library.version>
<junit5.version>5.8.1</junit5.version>
@@ -342,7 +342,7 @@ under the License.
<plugin>
<!-- activate API compatibility checks -->
- <groupId>io.github.zentol.japicmp</groupId>
+ <groupId>com.github.siom79.japicmp</groupId>
<artifactId>japicmp-maven-plugin</artifactId>
</plugin>
diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml
index eb62611..0e9a830 100644
--- a/tools/maven/checkstyle.xml
+++ b/tools/maven/checkstyle.xml
@@ -271,16 +271,10 @@ This file is based on the checkstyle file of Apache Beam.
<!-- Checks for Javadoc comments. -->
<!-- See http://checkstyle.sf.net/config_javadoc.html -->
<module name="JavadocMethod">
- <property name="scope" value="protected"/>
+ <property name="accessModifiers" value="protected"/>
<property name="severity" value="error"/>
- <property name="allowMissingJavadoc" value="true"/>
<property name="allowMissingParamTags" value="true"/>
<property name="allowMissingReturnTag" value="true"/>
- <property name="allowMissingThrowsTags" value="true"/>
- <property name="allowThrowsTagsForSubclasses"
value="true"/>
- <property name="allowUndeclaredRTE" value="true"/>
- <!-- This check sometimes failed for with "Unable to
get class information for @throws tag" for custom exceptions -->
- <property name="suppressLoadErrors" value="true"/>
</module>
<!-- Check that paragraph tags are used correctly in Javadoc.
-->
