Bingeng Huang

[SUPPORT]Unable to acquire lock when parallelism grows

1

I meet a situation where hudi table need 2 writers, one flink job writing new data, the other is for deleting old data. In flink job, use occ concurrency Control:...

[HUDI-6194] prevent flink writer getting the wrong instant to write

10

Flink write hudi If all task failover and send bootstrap event to `StreamWriteOperatorCoordinator`, and StreamWriteOperatorCoordinator happen to start a new instant i1 before receiving all the bootstrap events, the `AbstractStreamWriteFunction`...

[SUPPORT]IllegalStateException: Trying to access closed classloader

7

**Describe the problem you faced** flink job, stream read from hudi srouce and stream write to hudi sink. this error happen after run 4 hours, cause job to restart. java.lang.IllegalStateException:...