This is an automated email from the ASF dual-hosted git repository. jamesshao pushed a commit to branch upsert in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 47081392f736daca45dfb9bf857fb9dad804b99d Author: Bo Zhang <[email protected]> AuthorDate: Mon Nov 4 13:22:11 2019 -0800 Fix FixedPartitionCountBytesPartitionerTest Reviewers: #streaming_pinot, sjames Reviewed By: #streaming_pinot, sjames Differential Revision: https://code.uberinternal.com/D3546187 --- .../pinot/grigio/common/FixedPartitionCountBytesPartitionerTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pinot-grigio/pinot-grigio-coordinator/src/test/java/org/apache/pinot/grigio/common/FixedPartitionCountBytesPartitionerTest.java b/pinot-grigio/pinot-grigio-coordinator/src/test/java/org/apache/pinot/grigio/common/FixedPartitionCountBytesPartitionerTest.java index 9a4b818..567f5df 100644 --- a/pinot-grigio/pinot-grigio-coordinator/src/test/java/org/apache/pinot/grigio/common/FixedPartitionCountBytesPartitionerTest.java +++ b/pinot-grigio/pinot-grigio-coordinator/src/test/java/org/apache/pinot/grigio/common/FixedPartitionCountBytesPartitionerTest.java @@ -67,6 +67,9 @@ public class FixedPartitionCountBytesPartitionerTest { Cluster cluster = mock(Cluster.class); when(cluster.partitionCountForTopic(topic)).thenReturn(2); - partitioner.partition(topic, null, null, null, null, cluster); + String key = "test-key"; + byte[] keyBytes = key.getBytes(); + + partitioner.partition(topic, key, keyBytes, null, null, cluster); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
