[FLINK-36816] Support source parallelism setting for JDBC connector#148
[FLINK-36816] Support source parallelism setting for JDBC connector#148grzegorz8 wants to merge 2 commits intoapache:mainfrom
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.
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.
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.