-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.8.0, 1.8.1
-
Component/s: parquet-mr
-
Labels:None
flush() was added in RecordConsumer and MessageColumnIO to help implementing nulls caching.
However, other RecordConsumer implementations should also implements flush() properly. For instance, RecordConsumerLoggingWrapper and ValidatingRecordConsumer should call delegate.flush() in their flush() methods, otherwise data might be mistakenly truncated.
This ticket:
- makes flush() abstract in RecordConsumer
- implements flush() properly for all RecordConsumer subclasses, specifically:
- RecordConsumerLoggingWrapper
- ValidatingRecordConsumer
- ConverterConsumer
- ExpectationValidatingRecordConsumer
- blocks
-
PARQUET-401 Deprecate Log and move to SLF4J Logger
-
- Open
-
- links to