diff --git a/src/sst-convert/src/reader/remote_write.rs b/src/sst-convert/src/reader/remote_write.rs
index e6104e1191..9fec7a12ca 100644
--- a/src/sst-convert/src/reader/remote_write.rs
+++ b/src/sst-convert/src/reader/remote_write.rs
@@ -92,8 +92,7 @@ impl RemoteWriteReader {
         };
         let mut sorter = TimeSeriesSorter::new(encoder);
 
-        let reader = operator.reader(path).await.context(ObjectStoreSnafu)?;
-        let mut reader = TimeSeriesReader::new(reader).await?;
+        let mut reader = TimeSeriesParquetReader::new(operator, path).await?;
         while let Some(series) = reader.next_series().await? {
             sorter.push(series).await?;
         }