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
