Skip to content

Sharded cluster unblocked. Bump debezium version and base image - #83705

Draft
Rodi Reich Zilberman (rodireich) wants to merge 1 commit into
masterfrom
rodi/mongodb-sharded
Draft

Sharded cluster unblocked. Bump debezium version and base image#83705
Rodi Reich Zilberman (rodireich) wants to merge 1 commit into
masterfrom
rodi/mongodb-sharded

Conversation

@rodireich

Copy link
Copy Markdown
Contributor

What

How

Review guide

User Impact

Can this PR be safely reverted and rolled back?

  • YES 💚
  • NO ❌

@github-actions

github-actions Bot commented Aug 4, 2026

Copy link
Copy Markdown
Contributor

👋 Greetings, Airbyte Team Member!

Here are some helpful tips and reminders for your convenience.

💡 Show Tips and Tricks

PR Slash Commands

Airbyte Maintainers (that's you!) can execute the following slash commands on your PR:

  • 🛠️ Quick Fixes
    • /format-fix - Fixes most formatting issues.
    • /bump-version - Bumps connector versions, scraping changelog description from the PR title.
      • Bump types: patch (default), minor, major, major_rc, rc, promote.
      • The rc type is a smart default: applies minor_rc if stable, or bumps the RC number if already RC.
      • The promote type strips the RC suffix to finalize a release.
      • Example: /bump-version type=rc or /bump-version type=minor
    • /bump-progressive-rollout-version - Alias for /bump-version type=rc. Bumps with an RC suffix and enables progressive rollout.
  • ❇️ AI Testing and Review (internal link: AI-SDLC Docs):
    • /ai-prove-fix - Runs prerelease readiness checks, including testing against customer connections.
    • /ai-canary-prerelease - Rolls out prerelease to 5-10 connections for canary testing.
    • /ai-review - AI-powered PR review for connector safety and quality gates.
  • 📝 AI Documentation:
    • /ai-docs-review - AI-powered documentation review for PRs with connector changes.
    • /ai-create-docs-pr - Creates a documentation PR for connector changes, stacked on the current PR.
  • 🚀 Connector Releases:
    • /publish-connectors-prerelease - Publishes pre-release connector builds (tagged as {version}-preview.{git-sha}) for all modified connectors in the PR.
    • /enable-autopilot-rollouts - Enables autopilot progressive rollouts for the modified connector(s) in the PR, remediating "autopilot rollouts not enabled for {connector-name}" auto-merge blockers. Sets defaultRolloutMode: autopilot and enableProgressiveRollout: true, preserving any existing autopilotConfig.
      • Optional args: connector=<CONNECTOR_NAME> (defaults to the modified connectors in the PR), strategy=fast|slow|default (defaults to fast).
      • Example: /enable-autopilot-rollouts or /enable-autopilot-rollouts connector=source-faker strategy=slow
  • ☕️ JVM connectors:
    • /update-connector-cdk-version connector=<CONNECTOR_NAME> - Updates the specified connector to the latest CDK version.
      Example: /update-connector-cdk-version connector=destination-bigquery
  • 🐍 Python connectors:
    • /poe connector source-example lock - Run the Poe lock task on the source-example connector, committing the results back to the branch.
    • /poe source example lock - Alias for /poe connector source-example lock.
    • /poe source example use-cdk-branch my/branch - Pin the source-example CDK reference to the branch name specified.
    • /poe source example use-cdk-latest - Update the source-example CDK dependency to the latest available version.
  • ⚙️ Admin commands:
    • /force-merge reason="<REASON>" - Force merges the PR using admin privileges, bypassing CI checks. Requires a reason.
      Example: /force-merge reason="CI is flaky, tests pass locally"
📚 Show Repo Guidance

Helpful Resources

📝 Edit this welcome message.

@github-actions

github-actions Bot commented Aug 4, 2026

Copy link
Copy Markdown
Contributor

Note

Autopilot progressive rollouts are not enabled for the following modified connector(s):

  • source-mongodb-v2
  • source-postgres

This is a courtesy heads-up only — it does not block merge or fail any check.
To enable automatic progressive rollouts for the connector(s) above, comment
/enable-autopilot-rollouts on this PR. This sets defaultRolloutMode: autopilot
and enableProgressiveRollout: true in each connector's metadata.yaml,
preserving any existing autopilotConfig.

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

This PR appears to unblock MongoDB sharded cluster usage for the source-mongodb-v2 connector while also updating build/runtime dependencies (Debezium and the Java connector base image) to newer versions.

Changes:

  • Relax the MongoDB source check behavior so non–replica set cluster types no longer fail the connection check.
  • Bump source-mongodb-v2 base image and connector image tag, and update Debezium test-harness dependencies.
  • Update source-postgres connector CDK version configuration (currently set to local).

Reviewed changes

Copilot reviewed 4 out of 4 changed files in this pull request and generated 3 comments.

File Description
airbyte-integrations/connectors/source-postgres/gradle.properties Changes CDK version resolution for the source-postgres connector.
airbyte-integrations/connectors/source-mongodb-v2/src/main/java/io/airbyte/integrations/source/mongodb/MongoDbSource.java Adjusts source check behavior/logging for non–replica set cluster types.
airbyte-integrations/connectors/source-mongodb-v2/metadata.yaml Updates base image digest/tag and bumps connector docker image tag.
airbyte-integrations/connectors/source-mongodb-v2/build.gradle Updates Debezium dependencies used by the Debezium test harness configuration.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Comment on lines 100 to 102
if (!ClusterType.REPLICA_SET.equals(mongoClient.getClusterDescription().getType())) {
LOGGER.error("Target MongoDB instance is not a replica set cluster.");
return new AirbyteConnectionStatus()
.withMessage("Target MongoDB instance is not a replica set cluster.")
.withStatus(AirbyteConnectionStatus.Status.FAILED);
LOGGER.warn("Target MongoDB instance is not a replica set cluster.{}", mongoClient.getClusterDescription().getType());
}
Comment on lines +58 to +59
debeziumTestImplementation 'io.debezium:debezium-embedded:3.6.0.Final'
debeziumTestImplementation 'io.debezium:debezium-connector-mongodb:3.6.0.Final'
testExecutionConcurrency=-1
JunitMethodExecutionTimeout=5m
cdkVersion=1.1.8
cdkVersion=local
@github-actions

github-actions Bot commented Aug 4, 2026

Copy link
Copy Markdown
Contributor

Note

Detected that there are differences in the Gradle dependencies.

@github-actions

github-actions Bot commented Aug 4, 2026

Copy link
Copy Markdown
Contributor

source-mongodb-v2 Connector Test Results

 21 files   21 suites   1m 11s ⏱️
132 tests 131 ✅ 0 💤 1 ❌
136 runs  135 ✅ 0 💤 1 ❌

For more details on these failures, see this check.

Results for commit b18b831.

@github-actions

github-actions Bot commented Aug 4, 2026

Copy link
Copy Markdown
Contributor

source-postgres Connector Test Results

 14 files   14 suites   12m 33s ⏱️
 92 tests  92 ✅ 0 💤 0 ❌
286 runs  286 ✅ 0 💤 0 ❌

Results for commit b18b831.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants