Michal Nguyen
Michal Nguyen
So I double checked and there are differences between your example and our case. - We use content encoding `gzip` while saving our files to GCS, you don't have encoding...
For quick patch we use following solution: ``` class ReadAllFromTextNotSplittable(ReadAllFromText): """This class doesn't take advantage of splitting files in bundles because when doing so beam was taking compressed file size...
This is expected, as I mentioned earlier ```This leads us to using ReadAllFromText with parameter compression_type=CompressionTypes.UNCOMPRESSED since the downloaded file seems to be already uncompressed (it doesn't work with CompressionTypes.AUTO),...
Metadata is as follows (also please note we checked both `text/plain` and `application/x-gzip`, both were only partially read):