samza-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From criccom...@apache.org
Subject git commit: SAMZA-270; fix erasure warning in TestKeyValuePerformance
Date Wed, 04 Jun 2014 22:43:05 GMT
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 <raul@contxt.in>
Authored: Wed Jun 4 15:42:49 2014 -0700
Committer: Chris Riccomini <criccomi@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]]]


Mime
View raw message