loserwang1024 commented on code in PR #4498:
URL: https://github.com/apache/flink-cdc/pull/4498#discussion_r3892707355
##########
docs/content/docs/connectors/pipeline-connectors/fluss.md:
##########
@@ -100,6 +100,13 @@ Pipeline Connector Options
<td>String</td>
<td>The bootstrap servers for the Fluss sink connection. </td>
</tr>
+ <tr>
+ <td>sink.partitioning.strategy</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">DEFAULT</td>
+ <td>String</td>
+ <td>The partitioning strategy for DataChangeEvent routing. Available
values are <code>DEFAULT</code> and <code>FORWARD</code>. <code>DEFAULT</code>
hashes primary key tables by primary keys and routes log tables in round-robin
mode. <code>FORWARD</code> routes data events to downstream subtasks with the
same indices as upstream and is intended for Fluss-to-Fluss data
synchronization. The upstream data distribution must match the Fluss table
bucket distribution; otherwise, data correctness issues may occur.</td>
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
