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 <[email protected]> Authored: Wed Jun 4 15:42:49 2014 -0700 Committer: Chris Riccomini <[email protected]> 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]]]
