Skip connection validation when file access is denied (temporary workaround)#342
Open
Sarthak Sonagara (sonagaras) wants to merge 7 commits into
Open
Conversation
Temporary workaround for thread-based file access restrictions in Confluent Cloud. When validation runs on threads that don't have access to /mnt/secrets/, the connector now catches AccessDeniedException and skips connection validation with a warning. The connection will be properly validated when the task starts on a thread that has the required file access permissions. This workaround can be removed once the platform fix is implemented to include connector IDs in validation thread names. Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
The getMatchingCollections() method also creates a MongoDbConnection which triggers SSL context creation and can fail with AccessDeniedException when called from validation threads. Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
Added INFO log at start of validate() to confirm new code is running. Added detailed logging when exception is caught to debug if isFileAccessDenied() is working correctly. Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
…ictions Temporary workaround: Connection validation is skipped because validation threads (pool-*-thread-*) don't have access to /mnt/secrets/ in Confluent Cloud. Only task threads (lcc-*) have file access permissions. - validate() now skips validateConnection() entirely - getMatchingCollections() returns empty list immediately - Connection will be validated when the task starts on an allowed thread Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
…estrictions Temporary workaround: All validation is skipped because validation threads (pool-*-thread-*) don't have access to /mnt/secrets/ in Confluent Cloud. - start() skips validateAndRecord() entirely - validate() returns empty Config without calling validateAllFields() - getMatchingCollections() returns empty list immediately Validation will happen when the task starts on an allowed thread (lcc-*). Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
Temporary workaround: When file access is denied (AccessDeniedException) during SSL context creation, return a default SSL context instead of failing. This happens when validation runs on a thread without access to /mnt/secrets/ in Confluent Cloud. The actual SSL context with custom truststore will be created when the task starts on an allowed thread (lcc-*). Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
- Add check for "Access denied to thread" message pattern - Improve javadoc for isFileAccessDenied method - Use imported AccessDeniedException class directly Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Temporary workaround for thread-based file access restrictions in Confluent Cloud environments.
Problem
When the MongoDB connector runs validation, it attempts to read SSL truststore files from
/mnt/secrets/. However, theConnectFileSystemsecurity layer restricts file access based on thread names:lcc-*): ✅ Allowed accesspool-11-thread-*): ❌ Access deniedThis causes validation to fail with
AccessDeniedExceptioneven though the connector would work correctly once started.See: Oracle XStream CDC Connector - Wallet File Validation Failure
Solution
Skip connection validation when
AccessDeniedExceptionis caught:validateConnection()in try-catchThe connection will be properly validated when the task starts on a thread that has the required file access permissions.
Temporary Workaround
This fix can be removed once the platform team implements one of:
allowedPackagesinConnectFileSystemTest plan
AccessDeniedException🤖 Generated with Claude Code