-
Notifications
You must be signed in to change notification settings - Fork 4.8k
fix(clickhouse-dest): feature complete for speed mode #66562
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
👋 Greetings, Airbyte Team Member!Here are some helpful tips and reminders for your convenience. Helpful Resources
PR Slash CommandsAirbyte Maintainers (that's you!) can execute the following slash commands on your PR:
|
Note Detected that there are differences in the Gradle dependencies. |
core = 'load' | ||
toolkits = ['load-db'] | ||
cdk = '0.1.20' | ||
cdk = 'local' |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Did you mean to commit this change?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah since the PR is built on top of this, I need it to be local otherwise the the tests would fail
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's make sure to pin this before merge
|
||
private fun isValidVersionColumnType(airbyteType: AirbyteType): Boolean { | ||
// Must be of an integer type or of type Date/DateTime/DateTime64 | ||
val validTypes = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Consider making this a constant/file level field to avoid creating it each time this method is called.
# Conflicts: # airbyte-integrations/connectors/destination-clickhouse/build.gradle
|
This reverts commit 705c71e.
@Named("inputStreams") | ||
@Singleton | ||
fun stdInStreams() = ConnectorInputStreams(listOf(System.`in`)) | ||
fun stdInStreams(): List<InputStream> = listOf(System.`in`) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We need ConnectorInputStreams
to avoid issues with micronaut injection
Issue : https://github.com/airbytehq/airbyte-internal-issues/issues/14256 and https://github.com/airbytehq/airbyte-internal-issues/issues/14466