[Bug] [MongoDB-CDC] Can not find catalog with factoryId [MongoDB]

[amol64546]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

Not able to run MongoCDC to kafka job
getting issue Can not find catalog with factoryId [MongoDB]

SeaTunnel Version

2.3.8

SeaTunnel Config

{
    "env": {
        "job.mode": "STREAMING"
    },
    "source": [
        {
            "plugin_name": "MongoDB-CDC",
            "hosts": "my-mongodb:27017",
            "database": [
                "myDatabase"
            ],
            "collection": [
                "myDatabase.myCollection"
            ],
            "username": "root",
            "password": "cPudUKxnZV"
        }
    ],
    "transform": [],
    "sink": [
        {
            "plugin_name": "kafka",
            "topic": "test-topic",
            "bootstrap.servers": "kafka-service:9092",
            "format": "json",
            "kafka.request.timeout.ms": 60000,
            "semantics": "AT_LEAST_ONCE",
            "kafka.config": {
                "acks": "all",
                "request.timeout.ms": 60000,
                "buffer.memory": 8388608
            }
        }
    ]
}

Running Command

command: ["/bin/sh","-c","/opt/seatunnel/bin/seatunnel-cluster.sh -DJvmOption=-Xms2G -Xmx2G"]

Error Exception

[] 2025-01-20 13:28:09,047 WARN  [Log4j2HttpPostCommandProcessor] [hz.main.cached.thread-5] - [10.244.0.53]:5801 [seatunnel] [5.1] An error occurred while handling request HttpCommand [HTTP_POST]{uri='/hazelcast/rest/maps/submit-job'}AbstractTextCommand[HTTP_POST]{requestId=0}
org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'MongoDB-CDC'.
	at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:101) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:375) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.getLogicalDag(RestJobExecutionEnvironment.java:85) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestJobExecutionEnvironment.build(RestJobExecutionEnvironment.java:108) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.submitJobInternal(RestHttpPostCommandProcessor.java:177) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handleSubmitJob(RestHttpPostCommandProcessor.java:150) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:93) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.engine.server.rest.RestHttpPostCommandProcessor.handle(RestHttpPostCommandProcessor.java:69) ~[seatunnel-starter.jar:2.3.8]
	at com.hazelcast.internal.ascii.TextCommandServiceImpl$CommandExecutor.run(TextCommandServiceImpl.java:402) ~[seatunnel-starter.jar:2.3.8]
	at com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217) ~[seatunnel-starter.jar:2.3.8]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
	at java.lang.Thread.run(Thread.java:829) [?:?]
	at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) ~[seatunnel-starter.jar:2.3.8]
	at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.8]
Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: Can not find catalog with factoryId [MongoDB]
	at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$1(CatalogTableUtil.java:141) ~[seatunnel-starter.jar:2.3.8]
	at java.util.Optional.orElseThrow(Optional.java:408) ~[?:?]
	at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:138) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98) ~[seatunnel-starter.jar:2.3.8]
	at org.apache.seatunnel.connectors.seatunnel.cdc.mongodb.MongodbIncrementalSourceFactory.lambda$createSource$0(MongodbIncrementalSourceFactory.java:83) ~[connector-cdc-mongodb-2.3.8.jar:2.3.8]

Zeta or Flink or Spark Version

Zeta

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct