[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818347#comment-17818347
]
Lijie Wang commented on FLINK-34358:
------------------------------------
The exception stack in 1.18:
{code:java}
java.lang.UnsupportedOperationException: Unsupported type:TIMESTAMP_LTZ(3)
at
org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter.createInternalConverter(AbstractJdbcRowConverter.java:187)
at
org.apache.flink.connector.jdbc.databases.trino.dialect.TrinoRowConverter.createInternalConverter(TrinoRowConverter.java:60)
at
org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter.createNullableInternalConverter(AbstractJdbcRowConverter.java:118)
at
org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter.<init>(AbstractJdbcRowConverter.java:68)
at
org.apache.flink.connector.jdbc.databases.trino.dialect.TrinoRowConverter.<init>(TrinoRowConverter.java:40)
at
org.apache.flink.connector.jdbc.databases.trino.dialect.TrinoDialect.getRowConverter(TrinoDialect.java:49)
at
org.apache.flink.connector.jdbc.table.JdbcDynamicTableSource.getScanRuntimeProvider(JdbcDynamicTableSource.java:184)
at
org.apache.flink.table.planner.connectors.DynamicSourceUtils.validateScanSource(DynamicSourceUtils.java:478)
at
org.apache.flink.table.planner.connectors.DynamicSourceUtils.prepareDynamicSource(DynamicSourceUtils.java:161)
at
org.apache.flink.table.planner.connectors.DynamicSourceUtils.convertSourceToRel(DynamicSourceUtils.java:125)
at
org.apache.flink.table.planner.plan.schema.CatalogSourceTable.toRel(CatalogSourceTable.java:118)
at
org.apache.calcite.sql2rel.SqlToRelConverter.toRel(SqlToRelConverter.java:4002)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertIdentifier(SqlToRelConverter.java:2872)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverter.java:2432)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverter.java:2346)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertFrom(SqlToRelConverter.java:2291)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertSelectImpl(SqlToRelConverter.java:728)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertSelect(SqlToRelConverter.java:714)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertQueryRecursive(SqlToRelConverter.java:3848)
at
org.apache.calcite.sql2rel.SqlToRelConverter.convertQuery(SqlToRelConverter.java:618)
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$rel(FlinkPlannerImpl.scala:229)
at
org.apache.flink.table.planner.calcite.FlinkPlannerImpl.rel(FlinkPlannerImpl.scala:205)
at
org.apache.flink.table.planner.operations.SqlNodeConvertContext.toRelRoot(SqlNodeConvertContext.java:69)
at
org.apache.flink.table.planner.operations.converters.SqlQueryConverter.convertSqlNode(SqlQueryConverter.java:48)
at
org.apache.flink.table.planner.operations.converters.SqlNodeConverters.convertSqlNode(SqlNodeConverters.java:73)
at
org.apache.flink.table.planner.operations.SqlNodeToOperationConversion.convertValidatedSqlNode(SqlNodeToOperationConversion.java:272)
at
org.apache.flink.table.planner.operations.SqlNodeToOperationConversion.convert(SqlNodeToOperationConversion.java:262)
at
org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:106)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.sqlQuery(TableEnvironmentImpl.java:708)
at
org.apache.flink.connector.jdbc.dialect.JdbcDialectTypeTest.testDataTypeValidate(JdbcDialectTypeTest.java:101)
{code}
> flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"
> -----------------------------------------------------------------------------
>
> Key: FLINK-34358
> URL: https://issues.apache.org/jira/browse/FLINK-34358
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
> Reporter: Martijn Visser
> Assignee: Lijie Wang
> Priority: Blocker
> Labels: test-stability
>
> https://github.com/apache/flink-connector-jdbc/actions/runs/7770283211/job/21190280602#step:14:346
> {code:java}
> [INFO] Running
> org.apache.flink.connector.jdbc.dialect.cratedb.CrateDBDialectTypeTest
> Error: Tests run: 19, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
> 0.554 s <<< FAILURE! - in
> org.apache.flink.connector.jdbc.dialect.cratedb.CrateDBDialectTypeTest
> Error:
> org.apache.flink.connector.jdbc.dialect.cratedb.CrateDBDialectTypeTest.testDataTypeValidate(TestItem)[19]
> Time elapsed: 0.018 s <<< FAILURE!
> java.lang.AssertionError:
> Expecting code to raise a throwable.
> [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002
> s - in org.apache.flink.connector.jdbc.catalog.JdbcCatalogUtilsTest
> [INFO] Running org.apache.flink.architecture.ProductionCodeArchitectureTest
> [INFO] Running org.apache.flink.architecture.ProductionCodeArchitectureBase
> [INFO] Running org.apache.flink.architecture.rules.ApiAnnotationRules
> [INFO] Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.155
> s - in org.apache.flink.connector.jdbc.dialect.JdbcDialectTypeTest
> [INFO] Running org.apache.flink.architecture.TestCodeArchitectureTest
> [INFO] Running org.apache.flink.architecture.TestCodeArchitectureTestBase
> [INFO] Running org.apache.flink.architecture.rules.ITCaseRules
> [INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.109
> s - in org.apache.flink.architecture.rules.ApiAnnotationRules
> [INFO] Running org.apache.flink.architecture.rules.TableApiRules
> [INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.024
> s - in org.apache.flink.architecture.rules.TableApiRules
> [INFO] Running org.apache.flink.architecture.rules.ConnectorRules
> [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.31 s
> - in org.apache.flink.architecture.rules.ConnectorRules
> [INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.464
> s - in org.apache.flink.architecture.ProductionCodeArchitectureBase
> [INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.468
> s - in org.apache.flink.architecture.ProductionCodeArchitectureTest
> [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.758
> s - in org.apache.flink.architecture.rules.ITCaseRules
> [INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.761
> s - in org.apache.flink.architecture.TestCodeArchitectureTestBase
> [INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.775
> s - in org.apache.flink.architecture.TestCodeArchitectureTest
> [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 110.38
> s - in
> org.apache.flink.connector.jdbc.databases.oracle.xa.OracleExactlyOnceSinkE2eTest
> [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed:
> 172.591 s - in
> org.apache.flink.connector.jdbc.databases.db2.xa.Db2ExactlyOnceSinkE2eTest
> [INFO]
> [INFO] Results:
> [INFO]
> Error: Failures:
> Error:
> PostgresDialectTypeTest>JdbcDialectTypeTest.testDataTypeValidate:102
> Expecting code to raise a throwable.
> Error: TrinoDialectTypeTest>JdbcDialectTypeTest.testDataTypeValidate:102
> Expecting code to raise a throwable.
> Error: CrateDBDialectTypeTest>JdbcDialectTypeTest.testDataTypeValidate:102
> Expecting code to raise a throwable.
> [INFO]
> Error: Tests run: 394, Failures: 3, Errors: 0, Skipped: 1
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
