You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "hehuiyuan (Jira)" <ji...@apache.org> on 2023/07/20 02:42:00 UTC
[jira] [Created] (HUDI-6570) Cancel to send commit ack event when empty batch is not allowed to commit for flink batch job
hehuiyuan created HUDI-6570:
-------------------------------
Summary: Cancel to send commit ack event when empty batch is not allowed to commit for flink batch job
Key: HUDI-6570
URL: https://issues.apache.org/jira/browse/HUDI-6570
Project: Apache Hudi
Issue Type: Bug
Reporter: hehuiyuan
Cancel to send commit ack event when empty batch is not allowed to commit for flink batch job.
```java
Caused by: org.apache.flink.util.FlinkException: An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to ensure consistency. Event: 'org.apache.hudi.sink.event.CommitAckEvent@6834fa', targetTask: bucket_write: dmx_jdt_dmxlmt_cus_aum_after_mid_res_s_d (9/16) - execution #0
... 33 more
Caused by: org.apache.flink.runtime.operators.coordination.TaskNotRunningException: Task is not running, but in state FINISHED
```
There is a certain probability of failure in the flink batch job.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)