#622 fix(generate single output file)

gbif · Feb 16, 2022 · dd59900 · dd59900
1 parent 241bd35
commit dd59900
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...gatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/DistributionOutlierPipeline.java b/...gatlas/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");