danielxjd commented on a change in pull request #12786:
URL: https://github.com/apache/beam/pull/12786#discussion_r485260041
##########
File path:
sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java
##########
@@ -312,12 +362,14 @@ public ReadFiles withSplit() {
static class SplitReadFn extends DoFn<FileIO.ReadableFile, GenericRecord> {
private Class<? extends GenericData> modelClass;
private static final Logger LOG =
LoggerFactory.getLogger(SplitReadFn.class);
+ private String requestSchemaString;
Review comment:
Because the Schema class is not serializable so can only pass with
string.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
