THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

Dizzfire — Fri, 15 Nov 2024 23:33:22 GMT

Hi,

I have worked on TALEND v7.3.1 (Patch R2021-08).

My Route is connected to ActiveMQ Queue. When this route detected an entry in Queue, it executed talend Job with CtalendJob.

In this job, I used tHMAP component. However, When i executed this route with my job in karaf, I get this error:

org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

at org.apache.avro.io.JsonDecoder.error(JsonDecoder.java:698) ~[?:?]

at org.apache.avro.io.JsonDecoder.readIndex(JsonDecoder.java:441) ~[?:?]

at org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:290) ~[?:?]

at org.apache.avro.io.parsing.Parser.advance(Parser.java:88) ~[?:?]

at org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:267) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179) ~[?:?]

at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:116) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:222) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:175) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readMap(GenericDatumReader.java:313) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:178) ~[?:?]

at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:116) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:222) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:175) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:153) ~[?:?]

at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:145) ~[?:?]

at org.talend.transform.io.config.ConfigSerDe.deserialize(ConfigSerDe.java:167) ~[?:?]

at org.talend.transform.io.config.ConfigSerDe.deserializeAndClose(ConfigSerDe.java:138) ~[?:?]

at org.talend.transform.io.config.ConfigSerDe.deserialize(ConfigSerDe.java:113) ~[?:?]

at org.talend.transform.io.config.IOConfigSerDe.deserialize(IOConfigSerDe.java:31) ~[?:?]

at org.talend.transform.runtime.lib.ExecutorConfigBase.getIOProps(ExecutorConfigBase.java:112) ~[?:?]

at org.talend.transform.runtime.lib.MapExecutorConfig.<init>(MapExecutorConfig.java:74) ~[?:?]

at org.talend.transform.runtime.lib.MapExecutorConfig.<init>(MapExecutorConfig.java:62) ~[?:?]

at org.talend.transform.runtime.lib.MapExecutorImpl.createExecutorConfig(MapExecutorImpl.java:100) ~[?:?]

at org.talend.transform.runtime.lib.MapExecutorImpl.createExecutorConfig(MapExecutorImpl.java:67) ~[?:?]

at org.talend.transform.runtime.lib.ExecutorBase.setUpFunction(ExecutorBase.java:73) ~[?:?]

at org.talend.transform.runtime.lib.ExecutorBase.lambda$setUp$0(ExecutorBase.java:57) ~[?:?]

at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) ~[?:1.8.0_275]

at org.talend.transform.runtime.lib.ExecutorBase.setUp(ExecutorBase.java:57) ~[?:?]

at org.talend.transform.runtime.lib.MapExecutorMidImpl.setUp(MapExecutorMidImpl.java:49) ~[?:?]

at zpmc.zjmc_di_out_v02_000_baconsumemsgmbgmcr03_amb2emb_65_0.ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB.tRouteInput_1_LoopProcess(ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB.java:7573) [bundleFile:?]

at zpmc.zjmc_di_out_v02_000_baconsumemsgmbgmcr03_amb2emb_65_0.ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB.runJobInTOS(ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB.java:9766) [bundleFile:?]

at zpmc.zjmc_di_out_v02_000_baconsumemsgmbgmcr03_amb2emb_65_0.ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB$1.runSingleUseJob(ZJMC_DI_OUT_V02_000_BAConsumeMsgMBGMCR03_AMB2EMB.java:1402) [bundleFile:?]

at org.talend.camel.TalendProducer.invokeTalendJob(TalendProducer.java:203) [bundleFile:?]

Do you know this error ? I don't understand this message.

In karaf, I had feature talend-data-mapper and talend-data-mapper-dependencies.

Thank you

Re: THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

NGuittet — Mon, 13 Dec 2021 17:12:32 GMT

Same issue issue.

My tHMap is in a job called from a route (ESB Package), and I get the exact same 'org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT' exception while it executes properly within the Studio...

And the talend-data-mapper features are installed on my Karaf too.

Anyone ?

Re: THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

yome1 — Mon, 10 Jan 2022 15:20:02 GMT

Unfortunately, same error but no solutions for now...

topic THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT in Talend Studio

THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

Re: THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT

Re: THMAP - org.apache.avro.AvroTypeException: Expected start-union. Got END_OBJECT