SAMOA-58: Incorrect Samza artifact version.
Samza no longer produces separate serializers artifact.
isFinite since 1.8 - changed to work with what's available since 1.7
diff --git a/pom.xml b/pom.xml
index 191499f..edc49bd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -125,7 +125,7 @@
<kryo.version>2.21</kryo.version>
<metrics-core.version>2.2.0</metrics-core.version>
<miniball.version>1.0.3</miniball.version>
- <samza.version>0.10</samza.version>
+ <samza.version>0.10.0</samza.version>
<flink.version>0.10.1</flink.version>
<slf4j-log4j12.version>1.7.2</slf4j-log4j12.version>
<slf4j-simple.version>1.7.5</slf4j-simple.version>
diff --git a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
index 8c49537..2b36744 100644
--- a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
+++ b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
@@ -167,7 +167,9 @@
{
if (value instanceof Double) {
Double v = (double) value;
- if (Double.isFinite(v)) this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (double) value);
+ //if (Double.isFinite(v))
+ if (!Double.isNaN(v) && !Double.isInfinite(v))
+ this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (double) value);
}
else if (value instanceof Long)
this.setSparseValue(instance, indexValues, attributeValues, numAttribute, (long) value);
diff --git a/samoa-samza/pom.xml b/samoa-samza/pom.xml
index 945ae39..2ea0d98 100644
--- a/samoa-samza/pom.xml
+++ b/samoa-samza/pom.xml
@@ -62,12 +62,6 @@
<version>${samza.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.samza</groupId>
- <artifactId>samza-serializers_2.10</artifactId>
- <version>${samza.version}</version>
- </dependency>
-
<!--<dependency> <groupId>org.apache.samza</groupId> <artifactId>samza-shell</artifactId> <classifier>dist</classifier>
<type>tgz</type> <version>${samza.version}</version> </dependency> -->
