-
Notifications
You must be signed in to change notification settings - Fork 0
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
[Encryption] REST Integration #5
base: hive-fixes-and-spark-rest-merge
Are you sure you want to change the base?
[Encryption] REST Integration #5
Conversation
{ | ||
SparkCatalogConfig.REST.catalogName(), | ||
SparkCatalogConfig.REST.implementation(), | ||
appendCatalogEncryptionProperties( | ||
ImmutableMap.<String, String>builder() | ||
.putAll(SparkCatalogConfig.REST.properties()) | ||
.put(CatalogProperties.URI, restCatalog.properties().get(CatalogProperties.URI)) | ||
.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.
For some reason, three tests run for each test but I've only specified two parameters here.
@@ -122,7 +133,33 @@ public void testInsertAndDelete() { | |||
} | |||
|
|||
@TestTemplate | |||
public void testDirectDataFileRead() { | |||
public void testDirectUnencryptedDataFileRead() { |
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.
TODO: Remove changes to this file. Hive PR's test should suffice. Make ORDER BY
change there.
fe3230d
to
31fa050
Compare
|
||
@Disabled("Fails with `java.lang.IllegalStateException: Null key metadata buffer`") | ||
@TestTemplate | ||
public void testCtas() { |
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.
Why does this not work?
31fa050
to
c3440a9
Compare
.collect(Collectors.toList()), | ||
discardChanges ? ImmutableList.of() : ImmutableList.copyOf(changes)); | ||
|
||
result.setKekCache(kekCache); |
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.
Maybe add as a constructor parameter instead of doing this.
Base is #6. WIP.