Hi Bharath,
Below is configuration:
# App
app.name=canal-metrics
app.id=test
app.class=com.antfact.datacenter.canal.task.metrics.MetricsHandlerTask
task.class=com.antfact.datacenter.canal.task.metrics.MetricsHandlerTask
job.factory.class=org.apache.samza.job.yarn.YarnJobFactory
job.defaul
Hi Qi,
Can you share your application configuration? Especially the systems your
application consumes and produces to and its related configuration.
Also, would it be possible for to attach the entire log?
Thanks,
Bharath
On Tue, May 28, 2019 at 7:07 PM QiShu wrote:
> Hi,
>
> Below is