yuxiqian commented on PR #3619:
URL: https://github.com/apache/flink-cdc/pull/3619#issuecomment-2522253294

   Hi @liuxiao2shf, Seems current CI configuration doesn't really run test 
cases in `flink-cdc-base` package, and I couldn't get your newly added test 
case `MySqlSourceMetricsTest` to run successfully. Why this case isn't placed 
in `flink-connector-mysql-cdc` package? Could you please help take a look?
   
   ```
   Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to discover 
captured tables for enumerator
        at 
org.apache.flink.cdc.connectors.base.source.IncrementalSource.createEnumerator(IncrementalSource.java:166)
 ~[classes/:?]
        at 
org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:225)
 ~[flink-runtime-1.19.1.jar:1.19.1]
        ... 44 more
   Caused by: org.apache.flink.util.FlinkRuntimeException: 
java.lang.NumberFormatException: null
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.openJdbcConnection(MySqlDialect.java:83)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.discoverDataCollections(MySqlDialect.java:119)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.discoverDataCollections(MySqlDialect.java:53)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.source.IncrementalSource.createEnumerator(IncrementalSource.java:153)
 ~[classes/:?]
        at 
org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:225)
 ~[flink-runtime-1.19.1.jar:1.19.1]
        ... 44 more
   Caused by: java.lang.NumberFormatException: null
        at java.lang.Integer.parseInt(Integer.java:542) ~[?:1.8.0_202]
        at java.lang.Integer.valueOf(Integer.java:766) ~[?:1.8.0_202]
        at 
io.debezium.config.Configuration.lambda$getInteger$7(Configuration.java:1295) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at io.debezium.config.Configuration.getInteger(Configuration.java:1221) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at io.debezium.config.Configuration.getInteger(Configuration.java:1295) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at 
io.debezium.jdbc.JdbcConfiguration.getPort(JdbcConfiguration.java:339) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at 
org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory.getPoolId(JdbcConnectionPoolFactory.java:84)
 ~[classes/:?]
        at 
org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionFactory.connect(JdbcConnectionFactory.java:51)
 ~[classes/:?]
        at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at io.debezium.jdbc.JdbcConnection.connect(JdbcConnection.java:411) 
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.openJdbcConnection(MySqlDialect.java:81)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.discoverDataCollections(MySqlDialect.java:119)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.experimental.MySqlDialect.discoverDataCollections(MySqlDialect.java:53)
 ~[test-classes/:?]
        at 
org.apache.flink.cdc.connectors.base.source.IncrementalSource.createEnumerator(IncrementalSource.java:153)
 ~[classes/:?]
        at 
org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:225)
 ~[flink-runtime-1.19.1.jar:1.19.1]
        ... 44 more
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to