Airblader commented on a change in pull request #17350:
URL: https://github.com/apache/flink/pull/17350#discussion_r716420751
##########
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:
It's probably fine to leave that for now. That stack is deprecated as
well anyway, so migrating it to the new Schema stack is probably not worth it.
--
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]
