slinkydeveloper commented on a change in pull request #17350:
URL: https://github.com/apache/flink/pull/17350#discussion_r716418986
##########
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java
##########
@@ -164,7 +167,7 @@ private SourceProvider
createSourceProvider(BulkFormat<RowData, FileSourceSplit>
@Override
public TableSchema getSchema() {
- return schema;
+ return TableSchema.fromResolvedSchema(schema);
Review comment:
This code path should be hit if you're using the deprecated
`FileSystemFormatFactory`, used only by csv and avro formats. As a followup I
can work on migrating these 2 to the new factories, so we can prune this code
completely.
--
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]
