delta-io/connectors
This library allows Scala and Java-based projects (including Apache Flink, Apache Hive, Apache Beam, and PrestoDB) to read from and write to Delta Lake.
JavaApache-2.0
Issues
- 1
[0.5.1] Issue tracking
#477 opened by scottsand-db - 4
- 4
[Feature Request] Add `vacuum` API to DeltaLog
#484 opened by scottsand-db - 5
[Feature Request] Ensure that path is available as part of PendingFileRecoverable interface
#486 opened by gopik - 4
- 2
Delta standalone problem - snappy compression hardcoded for delta log parquet files
#490 opened by krzysztoflupa - 1
[Flink connector][Bug] Delta Sink - Metric name collision while creating DeltaWriterBucket metrics
#493 opened by kristoffSC - 1
- 2
[Flink connector][test][enhancement] - Create TableInfo class for Delta Source and Sing integration tests.
#499 opened by kristoffSC - 4
- 3
sql-delta-import.jar
#511 opened by vinitkhemka - 5
Scala incompatibility for Delta Flink connector when deploying connector jar to the Flink cluster.
#512 opened by kristoffSC - 4
Flink: Support Flink 1.17
#534 opened by PrabhuJoseph - 6
- 2
Add versions lag metric to DeltaSource
#537 opened by kwma3 - 1
External parquet files - trying to relativize path
#540 opened by aamend - 8
Delta Standalone: Jar Hell - Hadoop dependencies
#541 opened by VladimirPchelko - 2
[Delta-Standalone] create table
#544 opened by VladimirPchelko - 1
Scala library 2.13.8: CVE-2022-36944
#549 opened by ahmedriza - 1
Hadoop libraries and CVEs
#550 opened by ahmedriza - 1
- 4
- 3
- 1
Question: Delta Standalone - which version of the delta lake transaction log spec used?
#562 opened by csimplestring - 1
- 2
Flink Delta Connector end-to-end tests
#439 opened by rdziadosz - 8
Table cells are all NULL if the Delta Lake table were earlier saved with option "delta.columnMapping.mode" as "name"
#444 opened by ThachNgocTran - 2
CVE-2022-42004, CVE-2022-42003 with jackson-databind
#449 opened by zhudaxi - 3
- 1
- 4
- 1
HiveAccessControlException Permission denied: user [integration_user] does not have [RWSTORAGE] privilege on [deltastoragehandler://true/]
#560 opened by arijit999 - 1
Maturity custom connector delta
#548 opened by mvdwielen - 2
Flink DeltaSource should use Flink Configuration and not hadoop configuration
#522 opened by ramkrish86 - 11
- 2
- 1
- 0
- 3
- 1
Re-enable flaky flink-delta sink unit test
#470 opened by scottsand-db - 0
Migrate Flink-Delta connector to Flink 1.15.3 and re-enable Integration tests
#474 opened by kristoffSC - 0
[Flink-connector] - Use InitContext#getRestoredCheckpointId for checkpointId recovery
#481 opened by kristoffSC - 3
- 1
Flink Connector version 0.5.1-SNAPSHOT
#472 opened by ckavili - 1
Power BI Connector: Delta Sharing - Unable to work with tables stored in SSE-C encrypted S3
#459 opened by ThachNgocTran - 0
- 3
A row of null is added when loading a Delta Lake table, with data stored in S3, via Delta Sharing Server, to Power BI Desktop
#450 opened by ThachNgocTran - 1
external table using delta format
#446 opened by cometta - 1
[Question] How to ingest change data captured data from kafka to delta lake by Apache Flink?
#438 opened by ChenShuai1981 - 4
Non-optimal read for newly created Delta table from S3
#437 opened by dnskr