leaves12138 commented on code in PR #7737:
URL: https://github.com/apache/paimon/pull/7737#discussion_r3177760909
##########
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PostponeFixedBucketChannelComputer.java:
##########
@@ -55,7 +55,12 @@ public void setup(int numChannels) {
@Override
public int channel(InternalRow record) {
BinaryRow partition = partitionKeyExtractor.partition(record);
- int bucket = knownNumBuckets.computeIfAbsent(partition, p ->
numChannels);
+ int numBuckets = knownNumBuckets.computeIfAbsent(partition, p ->
numChannels);
+ int hash = partitionKeyExtractor.trimmedPrimaryKey(record).hashCode();
Review Comment:
Fixed automatically by Codex. `PostponeFixedBucketChannelComputer` now
reuses `FixedBucketRowKeyExtractor`, with
`FixedBucketRowKeyExtractor#bucket(int numBuckets)` added so postpone
fixed-bucket writes can still use the per-partition bucket count from
`knownNumBuckets`.
--
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]
