[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-10 Thread GitBox
tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1034694706 Hi @slinkydeveloper . Your observation is correct. Avro is a format that stores the schema in the file itself. When calling `DataFileReader.openReader` it will call

[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-09 Thread GitBox
tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1033468869 @flinkbot run azure -- 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

[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-08 Thread GitBox
tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1033411514 Azure passes in https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=324=results -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-08 Thread GitBox
tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1033269853 > @tsreaper Thanks, can you add a case for projection? There are already such tests, for example `AvroFilesystemITCase#testProjectPushDown`. -- This is an automated