Repository: incubator-samoa Updated Branches: refs/heads/master 0640831c5 -> bc92205bc
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 Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/7ecdc4b6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/7ecdc4b6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/7ecdc4b6 Branch: refs/heads/master Commit: 7ecdc4b6f07ccafd119a5d95c2d30453367c47ef Parents: a342340 Author: edi_bice <[email protected]> Authored: Mon Mar 14 14:49:12 2016 -0400 Committer: Gianmarco De Francisci Morales <[email protected]> Committed: Tue Apr 19 11:33:42 2016 +0300 ---------------------------------------------------------------------- pom.xml | 2 +- .../src/main/java/org/apache/samoa/instances/AvroLoader.java | 4 +++- samoa-samza/pom.xml | 6 ------ 3 files changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/7ecdc4b6/pom.xml ---------------------------------------------------------------------- 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> http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/7ecdc4b6/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java ---------------------------------------------------------------------- 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 @@ public abstract class AvroLoader implements Loader { { 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); http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/7ecdc4b6/samoa-samza/pom.xml ---------------------------------------------------------------------- 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> -->
