Hi,
I think the checkpointing is not the root cause of your job failure.
As the log describes, your job failed caused by the authorization
issue of Kafka. "Caused by:
org.apache.kafka.common.errors.TransactionalIdAuthorizationException:
Transactional Id authorization failed."
Best,
Yangze Guo
On
Hi Team,
We have recently enabled checking pointing using FsStateBackend where we
are trying to use S3 bucket as the persistent storage but after enabling it
we are running into issues while submitting the job into the cluster.
Can you please let us know if we are missing anything ?
Below is th
