snowflake-kafka-connector
snowflake-kafka-connector copied to clipboard
SNOW-630885 Schema Evolution (New SDK)
This PR contains changes specific to the latest updates in the Ingest SDK. It won't pass tests in the merge gate until a version of SDK is released.
Codecov Report
Merging #479 (fe34630) into master (edcdeb7) will decrease coverage by
3.65%
. The diff coverage is32.36%
.
@@ Coverage Diff @@
## master #479 +/- ##
==========================================
- Coverage 87.13% 83.47% -3.66%
==========================================
Files 46 46
Lines 3948 4200 +252
Branches 414 444 +30
==========================================
+ Hits 3440 3506 +66
- Misses 350 526 +176
- Partials 158 168 +10
Impacted Files | Coverage Δ | |
---|---|---|
.../kafka/connector/SnowflakeSinkConnectorConfig.java | 86.54% <ø> (ø) |
|
...owflake/kafka/connector/records/RecordService.java | 86.97% <ø> (+0.19%) |
:arrow_up: |
...snowflake/kafka/connector/SchematizationUtils.java | 35.05% <8.33%> (-14.95%) |
:arrow_down: |
...nnector/internal/SnowflakeConnectionServiceV1.java | 70.07% <26.36%> (-10.41%) |
:arrow_down: |
...ctor/internal/streaming/TopicPartitionChannel.java | 78.04% <41.80%> (-13.44%) |
:arrow_down: |
...tor/internal/streaming/SnowflakeSinkServiceV2.java | 75.58% <66.66%> (+0.28%) |
:arrow_up: |
...lake/kafka/connector/internal/SnowflakeErrors.java | 97.02% <100.00%> (+0.12%) |
:arrow_up: |
...fka/connector/internal/SnowflakeInternalStage.java | 68.75% <0.00%> (-5.00%) |
:arrow_down: |
:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more
Closing this since we have approved version of similar branch here: https://github.com/snowflakedb/snowflake-kafka-connector/pull/472