Created
April 15, 2021 08:01
-
-
Save bashir2/f4d6c86568fa7b9daab49fb3aad955d6 to your computer and use it in GitHub Desktop.
AvroTypeException while converting some Observation resources.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: org.apache.avro.AvroTypeException: Cannot encode decimal with scale 16 as scale 4 without rounding in field value in field quantity in field value | |
| at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:348) | |
| at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:318) | |
| at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:213) | |
| at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:67) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:317) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:303) | |
| at org.openmrs.analytics.FhirEtl.runFhirFetch(FhirEtl.java:174) | |
| at org.openmrs.analytics.FhirEtl.main(FhirEtl.java:245) | |
| Caused by: org.apache.avro.AvroTypeException: Cannot encode decimal with scale 16 as scale 4 without rounding in field value in field quantity in field value | |
| at org.apache.avro.generic.GenericDatumWriter.addAvroTypeMsg(GenericDatumWriter.java:198) | |
| at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:231) | |
| at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:210) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:131) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:73) | |
| at org.apache.beam.sdk.coders.AvroCoder.encode(AvroCoder.java:312) | |
| at org.apache.beam.sdk.coders.Coder.encode(Coder.java:136) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToSafeStream(CoderUtils.java:82) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToByteArray(CoderUtils.java:66) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToByteArray(CoderUtils.java:51) | |
| at org.apache.beam.sdk.util.CoderUtils.clone(CoderUtils.java:141) | |
| at org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector.<init>(MutationDetectors.java:115) | |
| at org.apache.beam.sdk.util.MutationDetectors.forValueWithCoder(MutationDetectors.java:46) | |
| at org.apache.beam.runners.direct.ImmutabilityCheckingBundleFactory$ImmutabilityEnforcingBundle.add(ImmutabilityCheckingBundleFactory.java:112) | |
| at org.apache.beam.runners.direct.ParDoEvaluator$BundleOutputManager.output(ParDoEvaluator.java:299) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:258) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.java:78) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:627) | |
| at org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:73) | |
| at org.openmrs.analytics.FetchSearchPageFn.processBundle(FetchSearchPageFn.java:121) | |
| at org.openmrs.analytics.FetchResources$2.ProcessElement(FetchResources.java:72) | |
| Caused by: org.apache.avro.AvroTypeException: Cannot encode decimal with scale 16 as scale 4 without rounding | |
| at org.apache.avro.Conversions$DecimalConversion.validate(Conversions.java:129) | |
| at org.apache.avro.Conversions$DecimalConversion.toBytes(Conversions.java:92) | |
| at org.apache.avro.Conversions$DecimalConversion.toBytes(Conversions.java:65) | |
| at org.apache.avro.Conversions.convertToRawType(Conversions.java:251) | |
| at org.apache.avro.generic.GenericDatumWriter.convert(GenericDatumWriter.java:107) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:81) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:145) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:221) | |
| at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:210) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:131) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:145) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:221) | |
| at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:210) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:131) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:145) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:221) | |
| at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:210) | |
| at org.apache.avro.generic.GenericDatumWriter.writeWithoutConversion(GenericDatumWriter.java:131) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:83) | |
| at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:73) | |
| at org.apache.beam.sdk.coders.AvroCoder.encode(AvroCoder.java:312) | |
| at org.apache.beam.sdk.coders.Coder.encode(Coder.java:136) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToSafeStream(CoderUtils.java:82) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToByteArray(CoderUtils.java:66) | |
| at org.apache.beam.sdk.util.CoderUtils.encodeToByteArray(CoderUtils.java:51) | |
| at org.apache.beam.sdk.util.CoderUtils.clone(CoderUtils.java:141) | |
| at org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector.<init>(MutationDetectors.java:115) | |
| at org.apache.beam.sdk.util.MutationDetectors.forValueWithCoder(MutationDetectors.java:46) | |
| at org.apache.beam.runners.direct.ImmutabilityCheckingBundleFactory$ImmutabilityEnforcingBundle.add(ImmutabilityCheckingBundleFactory.java:112) | |
| at org.apache.beam.runners.direct.ParDoEvaluator$BundleOutputManager.output(ParDoEvaluator.java:299) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:258) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.java:78) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:627) | |
| at org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:73) | |
| at org.openmrs.analytics.FetchSearchPageFn.processBundle(FetchSearchPageFn.java:121) | |
| at org.openmrs.analytics.FetchResources$2.ProcessElement(FetchResources.java:72) | |
| at org.openmrs.analytics.FetchResources$2$DoFnInvoker.invokeProcessElement(Unknown Source) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:224) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:185) | |
| at org.apache.beam.repackaged.direct_java.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78) | |
| at org.apache.beam.runners.direct.ParDoEvaluator.processElement(ParDoEvaluator.java:240) | |
| at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:54) | |
| at org.apache.beam.runners.direct.DirectTransformExecutor.processElements(DirectTransformExecutor.java:160) | |
| at org.apache.beam.runners.direct.DirectTransformExecutor.run(DirectTransformExecutor.java:124) | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:823) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment