Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[#6561] improvement(core): Cache Hadoop Filesystem instance on Gravitino server to improve the performance #6619

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

sunxiaojian
Copy link
Contributor

@sunxiaojian sunxiaojian commented Mar 6, 2025

What changes were proposed in this pull request?

Cache Hadoop Filesystem instance on Gravitino server to improve the performance

Why are the changes needed?

Fix: #6561

Does this PR introduce any user-facing change?

N/A

How was this patch tested?

N/A

@jerqi jerqi changed the title [#6561] improvement(core)Cache Hadoop Filesystem instance on Gravitino server to improve the performance [#6561] improvement(core): Cache Hadoop Filesystem instance on Gravitino server to improve the performance Mar 6, 2025
@sunxiaojian
Copy link
Contributor Author

@yuqi1129 PTAL, thanks

@yuqi1129
Copy link
Contributor

yuqi1129 commented Mar 8, 2025

I will take some time to verify whether this works in the loud filesystem as the related ITs are not triggered by default.

* @return The FileSystem instance.
* @throws IOException If the FileSystem instance cannot be created.
*/
default FileSystem getFileSystem(
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Will this method only be used by the Gravitino server?

@Nonnull Path path, @Nonnull Map<String, String> config, boolean disableCache)
throws IOException {
// disable cache
config.put(String.format("fs.%s.impl.disable.cache", scheme()), String.valueOf(disableCache));
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What if the config already contains key fs.%s.impl.disable.cache? will we cover it?

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.

Cache Hadoop Filesystem instance on Gravitino server to improve the performance
2 participants