[
https://issues.apache.org/jira/browse/FLINK-37963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37963.
--------------------------------
Fix Version/s: cdc-3.5.0
Assignee: yux
Resolution: Fixed
Fixed in master via b67ba29bed4ed6104ac8f6e831a2012da88960bd.
> Unstable MongoDB unit test cases that triggers JM failover
> ----------------------------------------------------------
>
> Key: FLINK-37963
> URL: https://issues.apache.org/jira/browse/FLINK-37963
> Project: Flink
> Issue Type: Sub-task
> Components: Flink CDC
> Reporter: yux
> Assignee: yux
> Priority: Minor
> Labels: pull-request-available
> Fix For: cdc-3.5.0
>
>
> [https://github.com/apache/flink-cdc/actions/runs/15509047609/job/43667549280]
>
> java.lang.NullPointerException
> at
> org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServicesWithLeadershipControl.grantJobMasterLeadership(EmbeddedHaServicesWithLeadershipControl.java:95)
>
> at
> org.apache.flink.cdc.connectors.mongodb.utils.MongoDBTestUtils.triggerJobManagerFailover(MongoDBTestUtils.java:134)
>
> at
> org.apache.flink.cdc.connectors.mongodb.utils.MongoDBTestUtils.triggerFailover(MongoDBTestUtils.java:120)
>
> at
> org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase.testRemoveCollectionsOneByOne(NewlyAddedTableITCase.java:572)
>
> at
> org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase.testJobManagerFailoverForRemoveCollectionSingleParallelism(NewlyAddedTableITCase.java:268)
>
> at java.lang.reflect.Method.invoke(Method.java:498)
> at java.util.ArrayList.forEach(ArrayList.java:1259)
> at java.util.ArrayList.forEach(ArrayList.java:1259)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
