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 2013/10/14 21:52:10 UTC
git commit: BUG FIX;
minor issue with SAMZA-56 commit with Scala 2.8.1.
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 <cr...@criccomi-mn.linkedin.biz>
Authored: Mon Oct 14 12:52:03 2013 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
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
}