[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044105#comment-17044105 ]
Jingsong Lee commented on FLINK-16265: -------------------------------------- I think the fix we can do could be comparing {{LogicalType}} in {{TableSchema.equals/hashCode}} instead of DataType with conversion classes. > TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema > are not supported yet for CsvTableSources. > ----------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-16265 > URL: https://issues.apache.org/jira/browse/FLINK-16265 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner > Affects Versions: 1.11.0 > Reporter: Robert Metzger > Assignee: Jingsong Lee > Priority: Major > Labels: test-stability > > https://travis-ci.org/apache/flink/jobs/654409371 > {code} > Dispatcher REST endpoint is up. > Running query #1... > Exception in thread "main" org.apache.flink.table.client.SqlClientException: > Unexpected exception. This is a bug. Please consider filing an issue. > at org.apache.flink.table.client.SqlClient.main(SqlClient.java:190) > Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could > not create execution context. > at > org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:779) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:228) > at org.apache.flink.table.client.SqlClient.start(SqlClient.java:98) > at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178) > Caused by: org.apache.flink.table.api.TableException: Encodings that differ > from the schema are not supported yet for CsvTableSources. > at > org.apache.flink.table.sources.CsvTableSourceFactoryBase.createTableSource(CsvTableSourceFactoryBase.java:127) > at > org.apache.flink.table.sources.CsvAppendTableSourceFactory.createStreamTableSource(CsvAppendTableSourceFactory.java:46) > at > org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:55) > at > org.apache.flink.table.factories.TableSourceFactory.createTableSource(TableSourceFactory.java:63) > at > org.apache.flink.table.factories.TableSourceFactory.createTableSource(TableSourceFactory.java:74) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:384) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:585) > at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:583) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:520) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:165) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:122) > at > org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:768) > ... 3 more > [FAIL] Test script contains errors. > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)