Skip to content

Commit

Permalink
[Source-Postgres] : Bump cdk, reduce timeout (#36865)
Browse files Browse the repository at this point in the history
  • Loading branch information
akashkulk authored Apr 10, 2024
1 parent 5e51b26 commit 1815e38
Show file tree
Hide file tree
Showing 13 changed files with 21 additions and 436 deletions.
1 change: 1 addition & 0 deletions airbyte-cdk/java/airbyte-cdk/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -144,6 +144,7 @@ Maven and Gradle will automatically reference the correct (pinned) version of th

| Version | Date | Pull Request | Subject |
|:--------|:-----------|:-----------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------|
| 0.29.11 | 2024-04-10 | [\#36865](https://github.com/airbytehq/airbyte/pull/36865) | Sources : Remove noisy log line. |
| 0.29.10 | 2024-04-10 | [\#36805](https://github.com/airbytehq/airbyte/pull/36805) | Destinations: Enhance CatalogParser name collision handling; add DV2 tests for long identifiers |
| 0.29.9 | 2024-04-09 | [\#36047](https://github.com/airbytehq/airbyte/pull/36047) | Destinations: CDK updates for raw-only destinations |
| 0.29.8 | 2024-04-08 | [\#36868](https://github.com/airbytehq/airbyte/pull/36868) | Destinations: s3-destinations Compilation fixes for connector |
Expand Down
Original file line number Diff line number Diff line change
@@ -1 +1 @@
version=0.29.10
version=0.29.11
Original file line number Diff line number Diff line change
Expand Up @@ -96,8 +96,6 @@ class DebeziumMessageProducer<T>(
if (checkpointOffsetToSend.size == 1 && !message!!.isSnapshotEvent) {
if (targetPosition.isEventAheadOffset(checkpointOffsetToSend, message)) {
shouldEmitStateMessage = true
} else {
LOGGER.info("Encountered records with the same event offset.")
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,8 @@ import org.slf4j.LoggerFactory
* type system.
*/
abstract class AbstractSourceDatabaseTypeTest : AbstractSourceConnectorTest() {
@JvmField val testDataHolders: MutableList<TestDataHolder> = ArrayList()

@JvmField var database: Database? = null
protected val testDataHolders: MutableList<TestDataHolder> = ArrayList()
protected var database: Database? = null

protected val idColumnName: String
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ java {
}

airbyteJavaConnector {
cdkVersionRequired = '0.29.0'
cdkVersionRequired = '0.29.11'
features = ['db-sources', 'datastore-postgres']
useLocalCdk = false
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
testExecutionConcurrency=-1

JunitMethodExecutionTimeout=5 m
JunitMethodExecutionTimeout=2 m
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ data:
connectorSubtype: database
connectorType: source
definitionId: decd338e-5647-4c0b-adf4-da0e75f5a750
dockerImageTag: 3.3.23
dockerImageTag: 3.3.24
dockerRepository: airbyte/source-postgres
documentationUrl: https://docs.airbyte.com/integrations/sources/postgres
githubIssueLabel: source-postgres
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 1815e38

Please sign in to comment.