[FLINK-36111][minor][pipeline-connector/paimon] Improve MultiTableCommittableChannelComputer Topology name

This closes #3559
pull/3629/head
MOBIN 5 months ago committed by GitHub
parent 78fda8b5ab
commit aedccb698e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -56,4 +56,9 @@ public class MultiTableCommittableChannelComputer
return Math.floorMod(Objects.hash(committableMessage), numChannels); return Math.floorMod(Objects.hash(committableMessage), numChannels);
} }
} }
@Override
public String toString() {
return "shuffle by table";
}
} }

Loading…
Cancel
Save