-
Notifications
You must be signed in to change notification settings - Fork 2.8k
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
Fix Azure http client leak in Azure filesystem #21982
Fix Azure http client leak in Azure filesystem #21982
Conversation
7ed766d
to
2fc79a0
Compare
@@ -116,14 +118,18 @@ private boolean isHierarchicalNamespaceEnabled() | |||
return fileSystemClient.getDirectoryClient("/").exists(); | |||
} | |||
catch (RuntimeException e) { | |||
throw new IOException("Failed to check whether hierarchical namespaces is enabled for the storage account %s and container %s".formatted(account, containerName)); | |||
throw new IOException("Failed to check whether hierarchical namespaces is enabled for the storage account %s and container %s" .formatted(account, containerName)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Extraneous space
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks! for some reason intellij reformat added this for me.
will try to reset the airbase code style.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i reimported airlift codestyle, but intellij still adds this space.
cc @trinodb/maintainers
...-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeAdlsConnectorSmokeTest.java
Show resolved
Hide resolved
<dependency> | ||
<groupId>io.trino</groupId> | ||
<artifactId>trino-filesystem-azure</artifactId> | ||
<scope>runtime</scope> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Could it be just test scoped? Same for the okhttp dependency above?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it is needed by tests, but also needed transitively.
we need to use runtime scope in such case, which sadly disables dep check
.configuration(clientOptions.getConfiguration()) | ||
.connectionTimeout(clientOptions.getConnectTimeout()) | ||
.writeTimeout(clientOptions.getWriteTimeout()) | ||
.readTimeout(clientOptions.getReadTimeout()) | ||
.connectionPool(new ConnectionPool(maximumConnectionPoolSize, | ||
clientOptions.getConnectionIdleTimeout().toMillis(), TimeUnit.MILLISECONDS)).build(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There may be potential for further config options in AzureFileSystemConfig
cc @anusudarsan
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ya we will have test internally with defaults and see if there is a need for it
2fc79a0
to
ea712ce
Compare
Found by #21913