Hi Tauseef,
This error is because your Class
com.hds.alta.pipeline.model.TopologyDTO cannot be serialized by ES
xcontent util.
The following solutions may fix it.
1. convert your TopologyDTO class data to a Map, and avoid using some
custom Class that cannot be serialized by ES.
or 2. make your To
Hi Phil,
correction: But the error
you have is a familiar error if you have written some code to handle
directory path. --> But the error
you have is a familiar error if you have written some code to handle
directory path with Java.
No offence.
Best regards.
Jiadong. Lu
Jiadong Lu 于2024年5月20日周
hi, Lu Niu
As a workaround, you could use the following ways to get the custom
accumulator you defined.
1. RestCluserClient#getAccumulators method
2. /jobs/:jobid/accumulators Rest API
Best.
Jiadong Lu
Lu Niu 于2025年4月29日周二 00:41写道：
>
> I am currently running a Flink job in batch mode and usin
; Lu
>
> On Mon, Apr 28, 2025 at 6:49 PM archzi lu wrote:
>>
>> hi, Lu Niu
>>
>> As a workaround, you could use the following ways to get the custom
>> accumulator you defined.
>> 1. RestCluserClient#getAccumulators method
>> 2. /jobs/:jobid/accumul
