You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
New Features
Added internal record buffering support via bufferCount and bufferFlushTime configuration options.
When enabled, records from multiple poll() calls are accumulated and flushed as a single large batch,
reducing the number of insert operations to ClickHouse. Buffering is disabled by default (bufferCount=0) for full backward compatibility. (#658)
Improvements
Report inserted offsets in preCommit() method. Previously connector was returning same map that is passed to
the method. This may lead to missed offsets in a situation of partition rebalance. Feature is turned off
by default and reportInsertedOffsets property should be set to true to enable. (#669)
Bug Fixes
Fixed invalid concurrency handling in ClickHouseWriter.updateMapping. Previously flag was set not in atomic way. (#678)
Fixes handling server error "Code 33" after schema is updated. Previously logic did not wait for target table to be updated.
After the fix logic will use describe of a single table when detects that updateMapping is running. (#680)