Updated Branches: refs/heads/master 0c3a3ac7b -> 63cc71c5f
BUG FIX; minor issue with SAMZA-56 commit with Scala 2.8.1. Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/63cc71c5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/63cc71c5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/63cc71c5 Branch: refs/heads/master Commit: 63cc71c5f750b8af615e85d46ab35871f6e777b2 Parents: 0c3a3ac Author: Chris Riccomini <[email protected]> Authored: Mon Oct 14 12:52:03 2013 -0700 Committer: Chris Riccomini <[email protected]> Committed: Mon Oct 14 12:52:03 2013 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/samza/serializers/IntegerSerde.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/63cc71c5/samza-core/src/main/scala/org/apache/samza/serializers/IntegerSerde.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/serializers/IntegerSerde.scala b/samza-core/src/main/scala/org/apache/samza/serializers/IntegerSerde.scala index 566fefa..3f219c8 100644 --- a/samza-core/src/main/scala/org/apache/samza/serializers/IntegerSerde.scala +++ b/samza-core/src/main/scala/org/apache/samza/serializers/IntegerSerde.scala @@ -31,7 +31,7 @@ class IntegerSerdeFactory extends SerdeFactory[Integer] { class IntegerSerde extends Serde[Integer] { def toBytes(obj: Integer): Array[Byte] = if (obj != null) { - ByteBuffer.allocate(4).putInt(obj).array + ByteBuffer.allocate(4).putInt(obj.intValue).array } else { null }
