Fix TempDataCompressor column numbers

hawkular · Jul 4, 2017 · 00bf3b7 · 00bf3b7
1 parent 08da6a6
commit 00bf3b7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/.../metrics-core-service/src/main/java/org/hawkular/metrics/core/service/DataAccessImpl.java b/.../metrics-core-service/src/main/java/org/hawkular/metrics/core/service/DataAccessImpl.java
@@ -822,7 +822,6 @@ private <T> Observable.Transformer<DataPoint<T>, BoundStatement> mapTempInsertSt
         MetricId<T> metricId = metric.getMetricId();
         return tO -> tO
                 .map(dataPoint -> {
-                    log.infof("------------> BucketIndex %d", getBucketIndex(dataPoint.getTimestamp()));
                     BoundStatement bs;
                     int i = 1;
                     if (dataPoint.getTags().isEmpty()) {

diff --git a/...ain/java/org/hawkular/metrics/core/service/transformers/TempTableCompressTransformer.java b/...ain/java/org/hawkular/metrics/core/service/transformers/TempTableCompressTransformer.java
@@ -97,11 +97,11 @@ public Observable<CompressedPointContainer> call(Observable<Row> dataRow) {
                             break;
                         case 1: // AVAILABILITY
                             // TODO Update to GORILLA_V2 to fix these - no point storing as FP
-                            compressor.addValue(timestamp, ((Byte) r.getByte(4)).doubleValue());
+                            compressor.addValue(timestamp, ((Byte) r.getByte(5)).doubleValue());
                             break;
                         case 2: // COUNTER
                             // TODO Update to GORILLA_V2 to fix these - no point storing as FP
-                            compressor.addValue(timestamp, ((Long) r.getLong(4)).doubleValue());
+                            compressor.addValue(timestamp, ((Long) r.getLong(6)).doubleValue());
                             break;
                         default:
                             // Not supported yet