You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/06/05 00:43:05 UTC
git commit: SAMZA-270; fix erasure warning in TestKeyValuePerformance
Repository: incubator-samza
Updated Branches:
refs/heads/master f68716d56 -> 39592d49a
SAMZA-270; fix erasure warning in TestKeyValuePerformance
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/39592d49
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/39592d49
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/39592d49
Branch: refs/heads/master
Commit: 39592d49a510e5baaa62d8cb00e08ba4a292ee40
Parents: f68716d
Author: Raul Castro Fernandez <ra...@contxt.in>
Authored: Wed Jun 4 15:42:49 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Wed Jun 4 15:42:49 2014 -0700
----------------------------------------------------------------------
.../apache/samza/test/performance/TestKeyValuePerformance.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/39592d49/samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala
----------------------------------------------------------------------
diff --git a/samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala b/samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala
index 5b9b926..0077af0 100644
--- a/samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala
+++ b/samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala
@@ -113,7 +113,7 @@ object TestKeyValuePerformance extends Logging {
null,
new SamzaContainerContext("test", config, partitions))
- val db = if (!engine.isInstanceOf[KeyValueStorageEngine[Array[Byte], Array[Byte]]]) {
+ val db = if (!engine.isInstanceOf[KeyValueStorageEngine[_, _]]) {
throw new SamzaException("This test can only run with KeyValueStorageEngine configured as store factory.")
} else {
engine.asInstanceOf[KeyValueStorageEngine[Array[Byte], Array[Byte]]]