Skip to content

[Backport] Make persists concurrent with adding rows in batch ingestion#11679

Merged
clintropolis merged 1 commit intoapache:0.22.0from
clintropolis:backport-11536-to-0.22.0
Sep 9, 2021
Merged

[Backport] Make persists concurrent with adding rows in batch ingestion#11679
clintropolis merged 1 commit intoapache:0.22.0from
clintropolis:backport-11536-to-0.22.0

Conversation

@clintropolis
Copy link
Copy Markdown
Member

Backport of #11536 to 0.22.0.

…11536)

* Make persists concurrent with ingestion

* Remove semaphore but keep concurrent persists (with add) and add push in the backround as well

* Go back to documented default persists (zero)

* Move to debug

* Remove unnecessary Atomics

* Comments on synchronization (or not) for sinks & sinkMetadata

* Some cleanup for unit tests but they still need further work

* Shutdown & wait for persists and push on close

* Provide support for three existing batch appenderators using batchProcessingMode flag

* Fix reference to wrong appenderator

* Fix doc typos

* Add BatchAppenderators class test coverage

* Add log message to batchProcessingMode final value, fix typo in enum name

* Another typo and minor fix to log message

* LEGACY->OPEN_SEGMENTS, Edit docs

* Minor update legacy->open segments log message

* More code comments, mostly small adjustments to naming etc

* fix spelling

* Exclude BtachAppenderators from Jacoco since it is fully tested but Jacoco still refuses to ack coverage

* Coverage for Appenderators & BatchAppenderators, name change of a method that was still using "legacy" rather than "openSegments"

Co-authored-by: Clint Wylie <cjwylie@gmail.com>
@clintropolis clintropolis added this to the 0.22.0 milestone Sep 8, 2021
@clintropolis
Copy link
Copy Markdown
Member Author

While this sort of bends the procedure we typically have for backports, which normally limits changes to bug fixes, api/config changes, and documentation improvements, my personal thoughts on this change is that since it is resolving a user facing API issue alongside the changes I consider it important enough to include in 0.22 so to prevent a future mess.

@lgtm-com
Copy link
Copy Markdown

lgtm-com Bot commented Sep 8, 2021

This pull request introduces 1 alert when merging ddefd9e into 59d2578 - view on LGTM.com

new alerts:

  • 1 for Uncontrolled data used in path expression

@clintropolis clintropolis merged commit a5e827d into apache:0.22.0 Sep 9, 2021
@clintropolis clintropolis deleted the backport-11536-to-0.22.0 branch September 9, 2021 03:02
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant