diff --git a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java index 316417b75b..f2b09cf8ab 100644 --- a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java +++ b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java @@ -178,6 +178,7 @@ public void processElement(ProcessContext c) { "Write to file", AvroIO.write(DistributionOutlierRecord.class) .to(outputPath + "/outlier") + .withoutSharding() .withSuffix(".avro")); log.info("Running the pipeline");