-
Notifications
You must be signed in to change notification settings - Fork 987
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
Allowing Jdbc FetchSize Configuration for handling large rows #2028
Allowing Jdbc FetchSize Configuration for handling large rows #2028
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #2028 +/- ##
============================================
+ Coverage 45.40% 52.97% +7.56%
+ Complexity 3680 1371 -2309
============================================
Files 843 378 -465
Lines 49989 20680 -29309
Branches 5261 2092 -3169
============================================
- Hits 22700 10955 -11745
+ Misses 25620 9045 -16575
+ Partials 1669 680 -989
|
...-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java
Outdated
Show resolved
Hide resolved
...-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java
Outdated
Show resolved
Hide resolved
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.
Comments around the help text, rest looks fine.
fcff0c4
to
510bda1
Compare
...rc/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java
Show resolved
Hide resolved
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.
LGTM
fb6922f
to
7d3a556
Compare
2f3e114
to
11bc6c2
Compare
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.
minor suggestion on config. Rest looks fine.
Allowing Jdbc FetchSize Configuration for handling large rows.
Overview
Default fetch size used by
JdbcIO
is 50_000 rows.Large (in terms of memory size) rows can lead to memory errors and
JdbcIO
recommends tuning fetch size in case of memory errors. Please see here.Here we allow the user to tune the fetch size via parameters.
Auto inference of fetchsize will be taken as a separate task as it needs careful scale testing.