Hyman_bz comments

Repositories
Issues
Comments

Results 2 comments of


                                            Hyman_bz

[Bug] The partition expire was not correctly triggered during the commit execution.

If my logic is correct, then I believe this issue is caused by the PartitionExpire instance not being reused. It can be resolved by recording the instance object in the...

[Bug] The partition expire was not correctly triggered during the commit execution.

> Just need add parameter `isEndInput` for committer to distinguish batch or streaming mode.只需要添加参数 `isEndInput` 供提交者区分批处理或流式处理模式。 My issue is not that the submitter cannot distinguish between batch processing and streaming...