This is an automated email from the ASF dual-hosted git repository.
fcsaky 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 029d95c [FLINK-39098] Bump testcontainers version to 1.21.4
029d95c is described below
commit 029d95ca2da80e3360dbab096bf33f0a0224b133
Author: Rahul Teke <[email protected]>
AuthorDate: Wed Mar 4 12:05:45 2026 +0000
[FLINK-39098] Bump testcontainers version to 1.21.4
---
.../connector/mongodb/table/MongoTablePlanTest.xml | 98 +++++++++++-----------
pom.xml | 2 +-
2 files changed, 50 insertions(+), 50 deletions(-)
diff --git
a/flink-connector-mongodb-table-tests/src/test/resources/org/apache/flink/connector/mongodb/table/MongoTablePlanTest.xml
b/flink-connector-mongodb-table-tests/src/test/resources/org/apache/flink/connector/mongodb/table/MongoTablePlanTest.xml
index b40cb1f..5ef0b10 100644
---
a/flink-connector-mongodb-table-tests/src/test/resources/org/apache/flink/connector/mongodb/table/MongoTablePlanTest.xml
+++
b/flink-connector-mongodb-table-tests/src/test/resources/org/apache/flink/connector/mongodb/table/MongoTablePlanTest.xml
@@ -16,75 +16,75 @@ See the License for the specific language governing
permissions and
limitations under the License.
-->
<Root>
- <TestCase name="testFilterPushdown">
- <Resource name="sql">
- <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo WHERE id = 900001
AND timestamp3_col <> TIMESTAMP '2022-09-07 10:25:28.127' OR double_col >=
-1000.23]]>
- </Resource>
- <Resource name="ast">
- <![CDATA[
+ <TestCase name="testFilterCannotPushdown">
+ <Resource name="sql">
+ <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo
WHERE id IS NOT NULL OR double_col = decimal_col]]>
+ </Resource>
+ <Resource name="ast">
+ <![CDATA[
LogicalProject(id=[$0], timestamp3_col=[$4], int_col=[$5])
-+- LogicalFilter(condition=[OR(AND(=($0, 900001), <>($4, CAST(2022-09-07
10:25:28.127:TIMESTAMP(3)):TIMESTAMP_WITH_LOCAL_TIME_ZONE(3) NOT NULL)), >=($6,
-1000.23:DECIMAL(6, 2)))])
++- LogicalFilter(condition=[OR(IS NOT NULL($0), =($6, CAST($7):DOUBLE))])
+- LogicalTableScan(table=[[default_catalog, default_database, mongo]])
]]>
- </Resource>
- <Resource name="optimized exec plan">
- <![CDATA[
-TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[and(OR(=(id, 900001:BIGINT), >=(double_col, -1000.23:DECIMAL(6, 2))),
OR(<>(timestamp3_col, 2022-09-07
10:25:28.127:TIMESTAMP_WITH_LOCAL_TIME_ZONE(3)), >=(double_col,
-1000.23:DECIMAL(6, 2))))], project=[id, timestamp3_col, int_col]]],
fields=[id, timestamp3_col, int_col])
+ </Resource>
+ <Resource name="optimized exec plan">
+ <![CDATA[
+Calc(select=[id, timestamp3_col, int_col], where=[(id IS NOT NULL OR
(double_col = CAST(decimal_col AS DOUBLE)))])
++- TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[], project=[id, timestamp3_col, int_col, double_col, decimal_col]]],
fields=[id, timestamp3_col, int_col, double_col, decimal_col])
]]>
- </Resource>
- </TestCase>
- <TestCase name="testFilterPartialPushdown">
- <Resource name="sql">
- <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo WHERE id = 900001
AND boolean_col = (decimal_col > 2.0)]]>
- </Resource>
- <Resource name="ast">
- <![CDATA[
+ </Resource>
+ </TestCase>
+ <TestCase name="testFilterPartialPushdown">
+ <Resource name="sql">
+ <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo
WHERE id = 900001 AND boolean_col = (decimal_col > 2.0)]]>
+ </Resource>
+ <Resource name="ast">
+ <![CDATA[
LogicalProject(id=[$0], timestamp3_col=[$4], int_col=[$5])
+- LogicalFilter(condition=[AND(=($0, 900001), =($2, >($7, 2.0:DECIMAL(2,
1))))])
+- LogicalTableScan(table=[[default_catalog, default_database, mongo]])
]]>
- </Resource>
- <Resource name="optimized exec plan">
- <![CDATA[
+ </Resource>
+ <Resource name="optimized exec plan">
+ <![CDATA[
Calc(select=[CAST(900001 AS BIGINT) AS id, timestamp3_col, int_col],
where=[(boolean_col = (decimal_col > 2.0))])
+- TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[=(id, 900001:BIGINT)], project=[boolean_col, timestamp3_col, int_col,
decimal_col]]], fields=[boolean_col, timestamp3_col, int_col, decimal_col])
]]>
- </Resource>
- </TestCase>
- <TestCase name="testFilterCannotPushdown">
- <Resource name="sql">
- <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo WHERE id IS NOT
NULL OR double_col = decimal_col]]>
- </Resource>
- <Resource name="ast">
- <![CDATA[
+ </Resource>
+ </TestCase>
+ <TestCase name="testFilterPushdown">
+ <Resource name="sql">
+ <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo
WHERE id = 900001 AND timestamp3_col <> TIMESTAMP '2022-09-07 10:25:28.127' OR
double_col >= -1000.23]]>
+ </Resource>
+ <Resource name="ast">
+ <![CDATA[
LogicalProject(id=[$0], timestamp3_col=[$4], int_col=[$5])
-+- LogicalFilter(condition=[OR(IS NOT NULL($0), =($6, CAST($7):DOUBLE))])
++- LogicalFilter(condition=[OR(AND(=($0, 900001), <>($4, CAST(2022-09-07
10:25:28.127:TIMESTAMP(3)):TIMESTAMP_WITH_LOCAL_TIME_ZONE(3) NOT NULL)), >=($6,
-1000.23:DECIMAL(6, 2)))])
+- LogicalTableScan(table=[[default_catalog, default_database, mongo]])
]]>
- </Resource>
- <Resource name="optimized exec plan">
- <![CDATA[
-Calc(select=[id, timestamp3_col, int_col], where=[(id IS NOT NULL OR
(double_col = CAST(decimal_col AS DOUBLE)))])
-+- TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[], project=[id, timestamp3_col, int_col, double_col, decimal_col]]],
fields=[id, timestamp3_col, int_col, double_col, decimal_col])
+ </Resource>
+ <Resource name="optimized exec plan">
+ <![CDATA[
+TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[and(OR(=(id, 900001:BIGINT), >=(double_col, -1000.23:DECIMAL(6, 2))),
OR(<>(timestamp3_col, 2022-09-07
10:25:28.127:TIMESTAMP_WITH_LOCAL_TIME_ZONE(3)), >=(double_col,
-1000.23:DECIMAL(6, 2))))], project=[id, timestamp3_col, int_col]]],
fields=[id, timestamp3_col, int_col])
]]>
- </Resource>
- </TestCase>
- <TestCase name="testNeverFilterPushdown">
- <Resource name="sql">
- <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo WHERE id = 900001
AND decimal_col > 1.0]]>
- </Resource>
- <Resource name="ast">
- <![CDATA[
+ </Resource>
+ </TestCase>
+ <TestCase name="testNeverFilterPushdown">
+ <Resource name="sql">
+ <![CDATA[SELECT id, timestamp3_col, int_col FROM mongo
WHERE id = 900001 AND decimal_col > 1.0]]>
+ </Resource>
+ <Resource name="ast">
+ <![CDATA[
LogicalProject(id=[$0], timestamp3_col=[$4], int_col=[$5])
+- LogicalFilter(condition=[AND(=($0, 900001), >($7, 1.0:DECIMAL(2, 1)))])
+- LogicalTableScan(table=[[default_catalog, default_database, mongo]])
]]>
- </Resource>
- <Resource name="optimized exec plan">
- <![CDATA[
+ </Resource>
+ <Resource name="optimized exec plan">
+ <![CDATA[
Calc(select=[CAST(900001 AS BIGINT) AS id, timestamp3_col, int_col],
where=[((id = 900001) AND (decimal_col > 1.0))])
+- TableSourceScan(table=[[default_catalog, default_database, mongo,
filter=[], project=[id, timestamp3_col, int_col, decimal_col]]], fields=[id,
timestamp3_col, int_col, decimal_col])
]]>
- </Resource>
- </TestCase>
+ </Resource>
+ </TestCase>
</Root>
diff --git a/pom.xml b/pom.xml
index aea6d86..6c7e316 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,7 +62,7 @@ under the License.
<scala-library.version>2.12.7</scala-library.version>
<junit5.version>5.8.1</junit5.version>
<assertj.version>3.21.0</assertj.version>
- <testcontainers.version>1.18.3</testcontainers.version>
+ <testcontainers.version>1.21.4</testcontainers.version>
<commons-compress.version>1.26.1</commons-compress.version>
<japicmp.skip>false</japicmp.skip>
