diff --git a/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java b/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java index 8a03def110e..e684b859fc1 100644 --- a/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java +++ b/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java @@ -140,6 +140,7 @@ private Array compressColFinally(int i, Future> f) throws Exception private Array allocateCorrectedType(int i) { final ArrayCompressionStatistics s = stats[i]; final Array a = in.getColumn(i); + if(s.valueType != a.getValueType()) return ArrayFactory.allocate(s.valueType, a.size(), s.containsNull); else @@ -226,11 +227,12 @@ private void logStatistics() { for(int i = 0; i < compressedColumns.length; i++) { if(in.getColumn(i) instanceof ACompressedArray) sb.append(String.format("Col: %3d, %s\n", i, "Column is already compressed")); - else if(stats[i].shouldCompress) - sb.append(String.format("Col: %3d, %s\n", i, stats[i])); else - sb.append(String.format("Col: %3d, No Compress, Type: %s\n", // - i, in.getColumn(i).getClass().getSimpleName())); + // if(stats[i].shouldCompress) + sb.append(String.format("Col: %3d, %s\n", i, stats[i])); + // else + // sb.append(String.format("Col: %3d, No Compress, Type: %s\n", // + // i, in.getColumn(i).getClass().getSimpleName())); } LOG.debug(sb); }