pnowojski commented on PR #20151: URL: https://github.com/apache/flink/pull/20151#issuecomment-1286649770
> As I understand, you mean that multiple ChannelStateWriterImpl share the same > ChannelStateWriteRequestExecutorImpl. When channel-state.number-of-tasks-share-file=5, each thread is responsible > for writing the channel state file for 5 subtasks, right? Since the file is written in a single thread, there is no need to consider thread safety issues. Yes, that's what I had in mind. > Your proposal should be clearer. I will try to refactor the code according to your proposal. Thanks again~ Great! But please keep in mind that I haven't thought it fully through and I haven't tried to implement it myself, so if you encounter some obstacles, feel free to reach out to me before going too deep! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
