JNSimba opened a new pull request, #511: URL: https://github.com/apache/doris-flink-connector/pull/511
# Proposed changes Fixed two issues: 1. Since the current cache is global, when there are multiple tables written upstream, such as tbl1, tbl2, tbl3, when the cached data of the three tables does not reach bufferFlushBytes, but reaches maxBlockBytes, the sinkwriter will be blocked at cache full When the intervalFlush thread calls the write, it will wait for a long time because it cannot obtain the lock, resulting in the inability to consume the cache. 2. If the flushqueue is full, the sinkwriter will be blocked at flushQueue.put(buffer); at this time, the streamload-executor thread will also call the doflush method after flush, and it will also be stuck because it cannot obtain the lock, and the data cannot be consumed. -- 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: commits-unsubscr...@doris.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
