-
Notifications
You must be signed in to change notification settings - Fork 4.3k
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
Destination Redshift: Add generation_id and sync_id #40201
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
This stack of pull requests is managed by Graphite. Learn more about stacking. |
5eea8ad
to
a07ab6e
Compare
1c20def
to
1750b55
Compare
a07ab6e
to
da81fd0
Compare
1750b55
to
2f51fd9
Compare
da81fd0
to
8a0951e
Compare
b22f4d9
to
4d34b0a
Compare
8a0951e
to
ddf5940
Compare
ddf5940
to
d84dd36
Compare
4d34b0a
to
0254987
Compare
d84dd36
to
af94f4d
Compare
9c7b93d
to
4398a4b
Compare
9b5a05f
to
a17ab12
Compare
5edb758
to
cf3e408
Compare
java.lang.String.join("\n", transaction) | ||
) | ||
log.info { | ||
"Executing sql $queryId-$transactionId: ${java.lang.String.join("\n", transaction)}" |
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.
use transaction.joinToString("\n") instead
@@ -113,7 +110,7 @@ class RedshiftDestinationHandler( | |||
logStatements = logStatements | |||
) | |||
} catch (e: SQLException) { | |||
log.error("Sql {}-{} failed", queryId, transactionId, e) | |||
log.error { "Sql $queryId-$transactionId failed" } |
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.
log.error(e) {...}
cf3e408
to
afa4805
Compare
ran two syncs in the perf test workspace with this version; verified that the tables got generation_id correctly
closes https://github.com/airbytehq/airbyte-internal-issues/issues/8358