Skip to content

Implement GzipByteBuffDecompressor and integrate with ReusableStreamG… - #258

Draft
SaadASTheDev wants to merge 31 commits into
hubspot-2.6from
gZipByteBuffDecompressor-hs26
Draft

Implement GzipByteBuffDecompressor and integrate with ReusableStreamG…#258
SaadASTheDev wants to merge 31 commits into
hubspot-2.6from
gZipByteBuffDecompressor-hs26

Conversation

@SaadASTheDev

Copy link
Copy Markdown

…zipCodec

hgromer and others added 20 commits July 16, 2026 09:01
…table mappings when using the bulk output option (not yet upstream)
Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
…ger can lead to data loss (not yet upstream)

Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
…#228)

* Fix an issue with duplicated backups of inactive host WAL files

* Skip meta region WAL files
… Region Info (not yet upstream)

Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
… regions without moving (apache#7563) (apache#7611) (#232) (will be in 2.7)

Signed-off-by: Ray Mattingly <rmattingly@apache.org>
Co-authored-by: Alex Hughes <ajkh88@users.noreply.github.com>
Co-authored-by: Alex Hughes <ahughes@hubspot.com>
…ith WAL Compression (not yet upstream)

* Initial changes to allow partial cell read in WAL

* Add tests

* More tests

* Add back comments

* Remove redundant tests and simplify

* Get tag value even if tag is out of bounds due to addition

* Clean up a bit

* Add explanatory comment

* Initialize to empty

* Resolve PR comment issue regarding LRU eviction for tags

* Address PR review: two-phase rollback and remove unused dictType param

Rollback in UndoableLRUDictionary previously restored nodes one at a time,
doing remove/setContents/put on the content-based nodeToIndex HashMap. This
could clobber entries when two nodes shared the same content during the
restore (e.g., an evicted value re-added to a different slot). The fix
restores all node state first, then rebuilds nodeToIndex from scratch.

Also removes the unused dictType parameter from TagCompressionContext since
every caller hardcodes LRUDictionary.class and we always need
UndoableLRUDictionary for correctness.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

---------

Co-authored-by: skhillon <skhillon@hubspot.com>
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>
…deletes subsequent COMPLETE backups (not yet upstream)

Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
…essors in region replication (CDC optimization)

* Filter cell. extended attributes and split oversized batches in region replica replication

Region replica replication was forwarding all extended attributes including
large "cell."-prefixed ones added by CDC coprocessors that have no use for
replicas. Strip these in replicate() before buffering to reduce memory and
network overhead.

Also add RPC size limit enforcement (matching HBaseInterClusterReplicationEndpoint)
to split batches that exceed hbase.ipc.max.request.size, preventing permanently
stalled replication.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Fix test compilation: add replicationRpcLimit parameter to test call sites

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Add unit tests for splitBatches and extract as package-private static method

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Remove controller.reset() between batch RPCs

reset() clears priority, callTimeout, tableName, and regionInfo which were
set by the superclass before call() was entered. Since setCellScanner is
called at the top of each loop iteration with the new batch's scanner,
no cleanup is needed between iterations.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Revert batch-splitting changes, keep only cell. attribute filtering

Scoping down to just the extended attribute filtering. The batch-splitting
for oversized RPCs will be addressed separately.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

---------

Co-authored-by: skhillon <skhillon@hubspot.com>
Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
…n 2.7)

Co-authored-by: Ray Mattingly <rmattingly@hubspot.com>
…emental backup bulkload copy (not yet upstream)

Co-authored-by: Hernan Gelaf-Romer <hgelafromer@hubspot.com>
…mpt to merge primary and secondary replicas (will be in 2.6.6)

* HubSpot Backport: HBASE-30299 Filter secondary replicas from region normalization planning

The SimpleRegionNormalizer.NormalizeContext was including secondary
replica regions in the list of table regions used for merge/split
planning. Add a filter to remove non-default replicas so only primary
regions are considered for normalization.

Cherry-picked from apache/hbase cd4fce2

* Add table name retrieval in test for secondary replica handling in region planning

---------

Co-authored-by: sahmadsabri <sahmadsabri@hubspot.com>
@SaadASTheDev
SaadASTheDev force-pushed the gZipByteBuffDecompressor-hs26 branch from 377b588 to 661f85d Compare August 4, 2026 17:28
@charlesconnell
charlesconnell force-pushed the hubspot-2.6 branch 3 times, most recently from 791eac7 to e414974 Compare August 9, 2026 22:57
sahmadsabri and others added 3 commits August 10, 2026 00:31
…buff

Brings in the latest versions of GzipByteBuffDecompressor, GzipHFileDecompressionContext, TestGzipByteBuffDecompressor, and TestHFileCompressionGzip from the HBASE-30321-gzipbytebuff branch.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Pulls latest refactor that removes heap decompression logic and supports only
direct-to-direct decompression via ZlibDirectDecompressor (zero-copy path).
Heap/mixed buffer callers fall back to the stream path.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants