diff --git a/dbcon/joblist/tupleaggregatestep.cpp b/dbcon/joblist/tupleaggregatestep.cpp index 24c1efa7e..9e7be1d62 100644 --- a/dbcon/joblist/tupleaggregatestep.cpp +++ b/dbcon/joblist/tupleaggregatestep.cpp @@ -1946,7 +1946,7 @@ void TupleAggregateStep::prep1PhaseDistinctAggregate( keysAgg.push_back(aggKey); scaleAgg.push_back(0); precisionAgg.push_back(-16); // for connector to skip null check - typeAgg.push_back(CalpontSystemCatalog::BIGINT); + //typeAgg.push_back(CalpontSystemCatalog::BIGINT); if (isUnsigned(typeProj[colProj])) { diff --git a/utils/rowgroup/rowgroup.cpp b/utils/rowgroup/rowgroup.cpp index a8bae1086..433ce04d7 100644 --- a/utils/rowgroup/rowgroup.cpp +++ b/utils/rowgroup/rowgroup.cpp @@ -1047,6 +1047,15 @@ RowGroup::RowGroup(uint32_t colCount, useStringTable = (stringTable && hasLongStringField); offsets = (useStringTable ? &stOffsets[0] : &oldOffsets[0]); + + for (i = 0; i < columnCount; i++) + { + if (types[i] == CalpontSystemCatalog::BIGINT && colWidths[i] != 8) + { + cout << "WTF?" << endl; + } + + } } RowGroup::RowGroup(const RowGroup& r) :