choucmei commented on PR #5560: URL: https://github.com/apache/seatunnel/pull/5560#issuecomment-1774610225
> @liugddx @Hisoka-X @ic4y @choucmei > > I modified the test case for MySQL e2e by changing one of the data to a null value for testing, and performed a null value query in the 'compareResult()' method. As shown in my modifications, strangely, I couldn't find the corresponding row. Can someone help me? > > PS. I checked the downlink after the test failed and found no row data。 > > ``` > 2023-10-20T07:27:00.8462436Z ==================== STDERR end ==================== > 2023-10-20T07:28:23.5926268Z 2023-10-20 07:28:23,555 ERROR org.apache.seatunnel.e2e.common.junit.TestLoggerExtension - > 2023-10-20T07:28:23.5928162Z -------------------------------------------------------------------------------- > 2023-10-20T07:28:23.5929955Z Test org.apache.seatunnel.connectors.seatunnel.jdbc.JdbcMysqlIT.testJdbcDb failed with: > 2023-10-20T07:28:23.5932776Z org.opentest4j.AssertionFailedError: Config [/jdbc_mysql_source_and_sink_parallel_upper_lower.conf] Null Columns' Data Count ==> expected: <1> but was: <0> ==> 'select * from seatunnel.sink where `c_decimal_unsigned_30` = ?' Result Row: <Not Row> > 2023-10-20T07:28:23.6010923Z at org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:152) > 2023-10-20T07:28:23.6076307Z at org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132) > 2023-10-20T07:28:23.6086910Z at org.apache.seatunnel.connectors.seatunnel.jdbc.JdbcMysqlIT.compareResult(JdbcMysqlIT.java:279) > 2023-10-20T07:28:23.6186085Z at org.apache.seatunnel.connectors.seatunnel.jdbc.AbstractJdbcIT.testJdbcDb(AbstractJdbcIT.java:293) > 2023-10-20T07:28:23.6188774Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > 2023-10-20T07:28:23.6192347Z at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > 2023-10-20T07:28:23.6194825Z at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > 2023-10-20T07:28:23.6196819Z at java.base/java.lang.reflect.Method.invoke(Method.java:566) > 2023-10-20T07:28:23.6201557Z at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727) > 2023-10-20T07:28:23.6203456Z at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) > 2023-10-20T07:28:23.6206097Z at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) > 2023-10-20T07:28:23.6208733Z at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156) > 2023-10-20T07:28:23.6210783Z at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147) > 2023-10-20T07:28:23.6272867Z at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94) > 2023-10-20T07:28:23.6335246Z at > ``` Because seatunnel partitioning requires a non-null partition key, you can add the primary column as the partition key. like this https://github.com/apache/seatunnel/pull/4812 -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
