You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2019/11/12 20:13:08 UTC
[incubator-pinot] 09/12: Fix FixedPartitionCountBytesPartitionerTest
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 <bz...@uber.com>
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: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org