linliu-code commented on code in PR #9572:
URL: https://github.com/apache/hudi/pull/9572#discussion_r1317566373
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStatsIndices.java:
##########
@@ -300,12 +298,7 @@ private static List<RowData> readColumnStatsIndexByColumns(
return records.collectAsList().stream().parallel().map(record -> {
// schema and props are ignored for generating metadata record from
the payload
// instead, the underlying file system, or bloom filter, or columns
stats metadata (part of payload) are directly used
- GenericRecord genericRecord;
- try {
- genericRecord = (GenericRecord)
record.getData().getInsertValue(null, null).orElse(null);
- } catch (IOException e) {
- throw new HoodieException("Exception while getting insert value
from metadata payload");
- }
+ GenericRecord genericRecord = (GenericRecord)
record.getData().toHoodieMetadataRecord().orElse(null);
Review Comment:
Yes, we can leave it as is. Sound like it will not block rfc-46. Will undo
the change for 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]
