Skip to content

Commit ebb3012

Browse files
committed
Fixed stream reading mode
1 parent 9a94cea commit ebb3012

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

‎composer.lock‎

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎src/Flow/ETL/Adapter/Avro/FlixTech/AvroExtractor.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ private function reader() : \AvroDataIOReader
7070
}
7171

7272
$this->reader = new \AvroDataIOReader(
73-
new AvroResource(Handler::file()->open($this->stream, Mode::READ)),
73+
new AvroResource(Handler::file()->open($this->stream, Mode::READ_BINARY)),
7474
new \AvroIODatumReader(null, null),
7575
);
7676

‎src/Flow/ETL/Adapter/Avro/FlixTech/AvroLoader.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ private function writer() : \AvroDataIOWriter
9898
$schema = \AvroSchema::parse($this->schema());
9999

100100
$this->writer = new \AvroDataIOWriter(
101-
new AvroResource($this->handler->open($this->stream, Mode::WRITE)),
101+
new AvroResource($this->handler->open($this->stream, Mode::WRITE_BINARY)),
102102
new \AvroIODatumWriter($schema),
103103
$schema,
104104
'null'

0 commit comments

Comments
 (0)