-
Notifications
You must be signed in to change notification settings - Fork 4.5k
✨Destination Iceberg: Bump Iceberg from 1.1.0 to 1.3.0 and add REST catalog support #28158
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
✨Destination Iceberg: Bump Iceberg from 1.1.0 to 1.3.0 and add REST catalog support #28158
Conversation
Before Merging a Connector Pull RequestWow! What a great pull request you have here! 🎉 To merge this PR, ensure the following has been done/considered for each connector added or updated:
If the checklist is complete, but the CI check is failing,
|
df32ec5
to
35103a1
Compare
implementation "software.amazon.awssdk:sts:2.17.257" | ||
implementation "software.amazon.awssdk:sdk-core:2.17.257" | ||
implementation "software.amazon.awssdk:aws-core:2.17.257" | ||
implementation "software.amazon.awssdk:utils:2.20.18" |
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.
this is to match the AWS SDK version being used by Iceberg: https://github.com/apache/iceberg/blob/apache-iceberg-1.3.0/versions.props#L24
@@ -27,6 +27,9 @@ public class IcebergConstants { | |||
public static final String JDBC_PASSWORD_CONFIG_KEY = "password"; | |||
public static final String JDBC_SSL_CONFIG_KEY = "ssl"; | |||
public static final String JDBC_CATALOG_SCHEMA_CONFIG_KEY = "catalog_schema"; | |||
public static final String REST_CATALOG_URI_CONFIG_KEY = "rest_uri"; | |||
public static final String REST_CATALOG_CREDENTIAL_CONFIG_KEY = "rest_credential"; |
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.
REST catalog uses either a token or a credential (both are optional) to interact with the REST server: https://github.com/apache/iceberg/blob/apache-iceberg-1.3.0/core/src/main/java/org/apache/iceberg/rest/auth/OAuth2Properties.java#L24-L28
@@ -0,0 +1,42 @@ | |||
version: "3" | |||
|
|||
services: |
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.
This is a slimmed down version of Iceberg's quickstart example: https://iceberg.apache.org/spark-quickstart/
Hello @nastra I added this our team's backlog and I'm going to review during the week. |
35103a1
to
f976b19
Compare
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 @nastra
/approve-and-merge reason="Connector still uses http requests which is going to be fix in next contribution" |
…talog support (airbytehq#28158) Co-authored-by: Marcos Marx <[email protected]>
What
This updates the Iceberg dependency from 1.1.0 to 1.3.0 and also adds REST catalog support
Pre-merge Actions
Expand the relevant checklist and delete the others.
Updating a connector
Community member or Airbyter
Airbyter
If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.