HBASE-27826 Refactor code to move creation of Ref files to SFT interface apis #5834

gvprathyusha6 · 2024-04-17T20:19:57Z

Modifies HStoreFile/StoreFileInfo constructors to take SFT interface as a parameter.
Refactors direct interactions of Reference/HFileLink creations to SFT interface. Also moves getStoreFiles/hasReferences from HRegionFS to SFT impls.
Use the SFT interface to list files of store everywhere instead of using FS objects directly

gvprathyusha6 · 2024-04-17T20:22:54Z

Modifies HStoreFile/StoreFileInfo constructors to take SFT interface as a parameter. Refactors direct interactions of Reference/HFileLink creations to SFT interface. Also moves getStoreFiles/hasReferences from HRegionFS to SFT impls. Use the SFT interface to list files of store everywhere instead of using FS objects directly

This POC PR is primarily to get a high level overview of the list of changes and is intended to be broken once the initial review is done.

…ace apis

Apache9

Checked the POC, overall good.

It is a pain that we need to touch the MOB related code.

Anyway, I think first we could first do some refactorings, to move the reference file related logic to StoreFileTracker, without changing any real logic. And then, another refactoring to move HFileLink, and back reference files related logic to StoreFileTracker. And finally, we start to change the implementation of StoreFileTracker, to implement the special logic for FileBasedStoreFileTracker, and also consider how to migrate between different store file tracker implementions.

WDYT?

Thanks.

Apache9 · 2024-04-18T03:45:55Z

...erver/src/main/java/org/apache/hadoop/hbase/master/assignment/SplitTableRegionProcedure.java

    int nbFiles = 0;
-    final Map<String, Collection<StoreFileInfo>> files =
-      new HashMap<String, Collection<StoreFileInfo>>(htd.getColumnFamilyCount());
+    final Map<String, Pair<Collection<StoreFileInfo>, StoreFileTracker>> files =


We need a separate StoreFileTracker for every StoreFile? Seems strange...

No we have a StoreFileTracker per column family here, we refactored current struct which contains [columnFamilyName] ---> [ Collection(StoreFileInfo) ] to
[columnFamilyName] ---> [ Collection(StoreFileInfo) + sft ]

Apache9 · 2024-04-18T03:49:32Z

...erver/src/main/java/org/apache/hadoop/hbase/master/assignment/SplitTableRegionProcedure.java

    @Override
    public Pair<Path, Path> call() throws IOException {
-      return splitStoreFile(regionFs, family, sf);
+      return splitStoreFile(regionFs, tracker, family, sf);


I think here we need to abstract at a higer level. As if we use file based store file tracker, we do not need multi threading. So we'd better abstract a method for splitting multiple store files in the store file tracker interface, and in the implementation, we are free to choose whether to use multi threading.

Yes if we can add this api as well in SFT, it will be easier to choose if where we want multi threading, but both impls might still need multi threading while initiating reader for all the parent store files while reading metadata for first/lastkeys.
But yes, we can get to it in detail as part of our last phase of implementation may be, where we want to commit all the ref/links in 1 go

Apache9 · 2024-04-18T03:52:35Z

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileInfo.java

  public StoreFileInfo(final Configuration conf, final FileSystem fs, final Path initialPath,
-    final boolean primaryReplica) throws IOException {
-    this(conf, fs, null, initialPath, primaryReplica);
+    final boolean primaryReplica, final StoreFileTracker sft) throws IOException {


I guess a better choice is to move these logics into StoreFileTracker, and make the constructor of StoreFileInfo simpler, so we do not need to pass so many parameters in...

you mean, we move the creation of StoreFileInfo itself to SFT, like SFT.getStoreFileInfo(path, primaryReplica) something like that right? yes this does look better to me.
Couple of trivial constructors like these we can have in StoreFileInfo and rest we can move to SFT interface

@Apache9 Should we also have the HStoreFile created using SFT apis then?

Apache9 · 2024-04-18T03:53:48Z

...main/java/org/apache/hadoop/hbase/regionserver/storefiletracker/DefaultStoreFileTracker.java

+   * @param familyName Column Family Name
+   * @return a set of {@link StoreFileInfo} for the specified family.
+   */
+  public List<StoreFileInfo> getStoreFiles(final String familyName, final boolean validate)


Why putting this method here and there is no @Override annotation? It is for DefaultStoreFileTracker only? Who will call it?

This is only helper method used as part of SFT#load() impl of DefaultStoreFileTracker, this was moved from HRegionFileSystem to here. This is not a new API we are adding

Apache9 · 2024-04-18T03:55:27Z

...rc/main/java/org/apache/hadoop/hbase/regionserver/storefiletracker/StoreFileTrackerBase.java

+    Path backRefPath = null;
+    if (params.isCreateBackRef()) {
+      Path backRefssDir = HFileLink.getBackReferencesDir(archiveStoreDir, params.getHfileName());
+      params.getFs().mkdirs(backRefssDir);


So for now, we just move the logic here, but still always create a file on filesystem?

Apache9 · 2024-04-18T03:58:01Z

...rc/main/java/org/apache/hadoop/hbase/regionserver/storefiletracker/StoreFileTrackerBase.java

+  }
+
+  @Override
+  public Reference createReference(Reference reference, Path path) throws IOException {


OK, so just a placeholder right? Later we will implement different ways to create reference file and check whether there are references right?

Yes thats correct, we will move it respective impl classes once we have the implementation of virtual links ready in FSFT

gvprathyusha6 · 2024-04-18T18:28:28Z

Checked the POC, overall good.

It is a pain that we need to touch the MOB related code.

Anyway, I think first we could first do some refactorings, to move the reference file related logic to StoreFileTracker, without changing any real logic. And then, another refactoring to move HFileLink, and back reference files related logic to StoreFileTracker. And finally, we start to change the implementation of StoreFileTracker, to implement the special logic for FileBasedStoreFileTracker, and also consider how to migrate between different store file tracker implementions.

WDYT?

Thanks.

Totally agree, we can target them 1 pr at a time.

to move the reference file related logic to StoreFileTracker
then, another refactoring to move HFileLink, and hasReference methods
then we start to change the implementation of StoreFileTracker, to implement the special logic for FileBasedStoreFileTracker to create virtual links
and commit all the ref files as part of split in 1 go

Thanks a lot for the review :)

Also around back references, we can support it as part of the api impl, but for the virtual links created as part of Split/Merge we dont need to create back references right? there are not moved to archive till these link files are compacted know

Apache-HBase · 2025-04-24T15:57:48Z

💔 -1 overall

Vote	Subsystem	Runtime	Logfile	Comment
+0 🆗	reexec	0m 32s		Docker mode activated.
			_ Prechecks _
+1 💚	dupname	0m 0s		No case conflicting files found.
+0 🆗	buf	0m 0s		buf was not available.
+0 🆗	buf	0m 0s		buf was not available.
+0 🆗	codespell	0m 0s		codespell was not available.
+0 🆗	detsecrets	0m 0s		detect-secrets was not available.
+1 💚	@author	0m 0s		The patch does not contain any @author tags.
+1 💚	hbaseanti	0m 0s		Patch does not have any anti-patterns.
			_ master Compile Tests _
+0 🆗	mvndep	0m 12s		Maven dependency ordering for branch
+1 💚	mvninstall	3m 52s		master passed
+1 💚	compile	4m 3s		master passed
+1 💚	checkstyle	0m 49s		master passed
+1 💚	spotbugs	4m 28s		master passed
+1 💚	spotless	0m 53s		branch has no errors when running spotless:check.
			_ Patch Compile Tests _
+0 🆗	mvndep	0m 10s		Maven dependency ordering for patch
+1 💚	mvninstall	3m 41s		the patch passed
+1 💚	compile	4m 2s		the patch passed
+1 💚	cc	4m 2s		the patch passed
+1 💚	javac	4m 2s		the patch passed
+1 💚	blanks	0m 0s		The patch has no blanks issues.
-0 ⚠️	checkstyle	0m 41s	/results-checkstyle-hbase-server.txt	hbase-server: The patch generated 2 new + 72 unchanged - 0 fixed = 74 total (was 72)
-1 ❌	spotbugs	2m 4s	/new-spotbugs-hbase-server.html	hbase-server generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
+1 💚	hadoopcheck	15m 36s		Patch does not cause any errors with Hadoop 3.3.6 3.4.0.
+1 💚	hbaseprotoc	1m 56s		the patch passed
+1 💚	spotless	1m 8s		patch has no errors when running spotless:check.
			_ Other Tests _
+1 💚	asflicense	0m 27s		The patch does not generate ASF License warnings.
		56m 50s

Reason	Tests
SpotBugs	module:hbase-server
	Dead store to infos in org.apache.hadoop.hbase.regionserver.HRegionFileSystem.commitMergedRegion(List, MasterProcedureEnv) At HRegionFileSystem.java:org.apache.hadoop.hbase.regionserver.HRegionFileSystem.commitMergedRegion(List, MasterProcedureEnv) At HRegionFileSystem.java:[line 773]

Subsystem	Report/Notes
Docker	ClientAPI=1.43 ServerAPI=1.43 base: https://ci-hbase.apache.org/job/HBase-PreCommit-GitHub-PR/job/PR-5834/3/artifact/yetus-general-check/output/Dockerfile
GITHUB PR	#5834
Optional Tests	dupname asflicense cc buflint bufcompat codespell detsecrets hbaseprotoc spotless javac spotbugs checkstyle compile hadoopcheck hbaseanti
uname	Linux 266b8a011966 5.4.0-1103-aws #111~18.04.1-Ubuntu SMP Tue May 23 20:04:10 UTC 2023 x86_64 x86_64 x86_64 GNU/Linux
Build tool	maven
Personality	dev-support/hbase-personality.sh
git revision	master / `5d18437`
Default Java	Eclipse Adoptium-17.0.11+9
Max. process+thread count	85 (vs. ulimit of 30000)
modules	C: hbase-protocol-shaded hbase-server U: .
Console output	https://ci-hbase.apache.org/job/HBase-PreCommit-GitHub-PR/job/PR-5834/3/console
versions	git=2.34.1 maven=3.9.8 spotbugs=4.7.3
Powered by	Apache Yetus 0.15.0 https://yetus.apache.org

This message was automatically generated.

Apache-HBase · 2025-04-24T23:45:55Z

💔 -1 overall

Vote	Subsystem	Runtime	Logfile	Comment
+0 🆗	reexec	0m 29s		Docker mode activated.
-0 ⚠️	yetus	0m 3s		Unprocessed flag(s): --brief-report-file --spotbugs-strict-precheck --author-ignore-list --blanks-eol-ignore-file --blanks-tabs-ignore-file --quick-hadoopcheck
			_ Prechecks _
			_ master Compile Tests _
+0 🆗	mvndep	0m 13s		Maven dependency ordering for branch
+1 💚	mvninstall	4m 0s		master passed
+1 💚	compile	1m 47s		master passed
+1 💚	javadoc	0m 46s		master passed
+1 💚	shadedjars	6m 36s		branch has no errors when building our shaded downstream artifacts.
			_ Patch Compile Tests _
+0 🆗	mvndep	0m 12s		Maven dependency ordering for patch
+1 💚	mvninstall	3m 55s		the patch passed
+1 💚	compile	2m 5s		the patch passed
+1 💚	javac	2m 5s		the patch passed
-0 ⚠️	javadoc	0m 44s	/results-javadoc-javadoc-hbase-server.txt	hbase-server generated 3 new + 63 unchanged - 0 fixed = 66 total (was 63)
+1 💚	shadedjars	9m 38s		patch has no errors when building our shaded downstream artifacts.
			_ Other Tests _
+1 💚	unit	0m 48s		hbase-protocol-shaded in the patch passed.
-1 ❌	unit	464m 57s	/patch-unit-hbase-server.txt	hbase-server in the patch failed.
		524m 40s

Subsystem	Report/Notes
Docker	ClientAPI=1.43 ServerAPI=1.43 base: https://ci-hbase.apache.org/job/HBase-PreCommit-GitHub-PR/job/PR-5834/3/artifact/yetus-jdk17-hadoop3-check/output/Dockerfile
GITHUB PR	#5834
Optional Tests	unit javac javadoc compile shadedjars
uname	Linux 172d7ceb769d 5.4.0-1103-aws #111~18.04.1-Ubuntu SMP Tue May 23 20:04:10 UTC 2023 x86_64 x86_64 x86_64 GNU/Linux
Build tool	maven
Personality	dev-support/hbase-personality.sh
git revision	master / `5d18437`
Default Java	Eclipse Adoptium-17.0.11+9
Test Results	https://ci-hbase.apache.org/job/HBase-PreCommit-GitHub-PR/job/PR-5834/3/testReport/
Max. process+thread count	4618 (vs. ulimit of 30000)
modules	C: hbase-protocol-shaded hbase-server U: .
Console output	https://ci-hbase.apache.org/job/HBase-PreCommit-GitHub-PR/job/PR-5834/3/console
versions	git=2.34.1 maven=3.9.8
Powered by	Apache Yetus 0.15.0 https://yetus.apache.org

This message was automatically generated.

HBASE-27826 Refactor code to move creation of Ref files to SFT interf…

03596b9

…ace apis

gvprathyusha6 force-pushed the HBASE-27826 branch from 93935f8 to 03596b9 Compare April 17, 2024 20:53

This comment has been minimized.

Sign in to view

Apache9 reviewed Apr 18, 2024

View reviewed changes

gvprathyusha6 requested a review from Apache9 April 19, 2024 14:39

gvprathyusha6 force-pushed the HBASE-27826 branch 2 times, most recently from 5d18437 to 03596b9 Compare April 24, 2025 15:08

HBASE-27826 Refactor code to move creation of Ref files to SFT interface apis #5834

Are you sure you want to change the base?

HBASE-27826 Refactor code to move creation of Ref files to SFT interface apis #5834

Conversation

gvprathyusha6 commented Apr 17, 2024

Uh oh!

gvprathyusha6 commented Apr 17, 2024

Uh oh!

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

This comment has been minimized.

Apache9 left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

gvprathyusha6 Apr 18, 2024 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

gvprathyusha6 commented Apr 18, 2024 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

Apache-HBase commented Apr 24, 2025

Uh oh!

Apache-HBase commented Apr 24, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

gvprathyusha6 Apr 18, 2024 •

edited

Loading

gvprathyusha6 commented Apr 18, 2024 •

edited

Loading