-
Notifications
You must be signed in to change notification settings - Fork 205
[FLINK-36816] Support source parallelism setting for JDBC connector #148
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
base: main
Are you sure you want to change the base?
Conversation
| <a href="https://jdbc.postgresql.org/documentation/head/query.html#query-with-cursor">Postgres</a>,可能需要将此设置为 false 以便流化结果。</td> | ||
| </tr> | ||
| <tr> | ||
| <td><h5>scan.parallelism</h5></td> |
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.
could you add a link to some documentation for this - as there is for autocommit please.
|
This PR is being marked as stale since it has not had any activity in the last 90 days. If you are having difficulty finding a reviewer, please reach out to the If this PR is no longer valid or desired, please feel free to close it. |
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.
Thanks @grzegorz8 for the contribution .
Could you still work for this patch ?
If there is no response for an extended period, we will try to find other developers to continue advancing this patch. BTW, your initial contribution will be retained as a co-author in the commit message.
Looking forward to your back or reply!
H! I'll try to rebase my PR with main soon. |
Purpose of the change
Add new option
scan.parallelismsupport for JDBC connector.Part of FLINK-33261 FLIP-367: Support Setting Parallelism for Table/SQL Sources
The change is not backward compatible for versions <= 1.18.
InputFormatProvider of(InputFormat<RowData, ?> inputFormat, @Nullable Integer sourceParallelism)was added in Flink 1.19. Therefore, we need to wait with this change until JDBC connector is no longer supporting Flink 1.18.