Skip to content
This repository was archived by the owner on May 6, 2022. It is now read-only.

Commit 1c17987

Browse files
committed
#52 Removed wrong RDD caching
1 parent e37c565 commit 1c17987

File tree

1 file changed

+0
-1
lines changed
  • chronix-spark-ts-rdd/src/main/java/de/qaware/chronix/spark/api/java

1 file changed

+0
-1
lines changed

chronix-spark-ts-rdd/src/main/java/de/qaware/chronix/spark/api/java/ChronixRDD.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,6 @@ public ChronixRDD filterByDimensions(Map<String, String> dimensionFilter, boolea
165165
public ChronixRDD joinChunks() {
166166
JavaPairRDD<MetricTimeSeriesKey, Iterable<MetricTimeSeries>> groupRdd
167167
= this.groupBy(MetricTimeSeriesKey::new);
168-
groupRdd.cache();
169168

170169
JavaPairRDD<MetricTimeSeriesKey, MetricTimeSeries> joinedRdd
171170
= groupRdd.mapValues((Function<Iterable<MetricTimeSeries>, MetricTimeSeries>) mtsIt -> {

0 commit comments

Comments
 (0)