Skip to content

WIP initial steps for distributing compaction coordination#6217

Draft
keith-turner wants to merge 13 commits intoapache:mainfrom
keith-turner:dist-coord
Draft

WIP initial steps for distributing compaction coordination#6217
keith-turner wants to merge 13 commits intoapache:mainfrom
keith-turner:dist-coord

Conversation

@keith-turner
Copy link
Contributor

Some initial steps for distributing compaction coordinator. Currently only contains the following.

  • Creates a map in ZK that maps compactor resource group to a manager process. Currently maps all RGs to the primary manager.
  • Modified the compactor processes to consult this map to find which coordinator to use.
  • A periodic task running in the primary manager that updates this map in ZK

Still need to do the following

  • Delegate compactor resource groups to assistant managers. Will require refactoring existing code and a new RPC.
  • Modify TGW to stream compaction jobs to remote assistant managers.
  • Refactor all the cleanup code that runs in the coordinator to only run in the primary manager
  • Potentially move the in memory tracking the coordinator currently does to the monitor.
  • Correctly create the map of compactor RGs to assistant managers in ZK.

Plan to continue experimenting with this.

There is still only one coordinator, but now the TGW and compactors both
could talk to multiple coordinators.
The set of shutting down tservers was causing system fate operations to
have to run on the primary manager because this was an in memory set.
This caused fate to have different code paths to user vs system fate,
this in turn caused problems when trying to distribute compaction
coordination.

To fix this problem moved the set from an in memory set to a set in
zookeeper.  The set is managed by fate operations which simplifies the
existing code. Only fate operations add and remove from the set and fate
keys are used to ensure only one fate operation runs at a time for a
tserver instance.  The previous in memory set had a lot of code to try to keep
it in sync with reality, that is all gone now.  There were many bugs with
this code in the past.

After this change is made fate can be simplified in a follow on commit
to remove all specialization for the primary manager.  Also the monitor
can now directly access this set instead of making an RPC to the
manager, will open a follow on issue for this.
After this change meta fate and user fate are both treated mostly the
same in the managers.  One difference is in assignment, the entire meta
fate range is assigned to a single manager.  User fate is spread across
all managers.  But both are assigned out by the primary manager using
the same RPCs now.  The primary manager used to directly start a meta
fate instance.

Was able to remove the extension of FateEnv from the manager class in
this change, that caused a ripple of test changes.  But now there are no
longer two different implementations of FateEnv
Before this change a fate client was only available on the primary
manager. Now fate clients are avaiable on all managers.  The primary
manager publishes fate assignment locations in zookeeper.  These
locations are used by managers to send notifications to other managers
when they seed a fate operation.
@keith-turner
Copy link
Contributor Author

After merging in the changes from #6232 a basic test of compaction coordination spread across multiple managers is now working. Was failing before. Still alot of loose ends and refactoring that is needed, but the basic functionality seems to be working now.

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.

1 participant