提交 4fc5cc33 编写于 作者: L lican 提交者: wu-sheng

fix_average_duration_zero (#1164)

上级 89d79012
......@@ -82,6 +82,7 @@ public abstract class AggregationWorker<INPUT extends StreamData, OUTPUT extends
if (mergeDataCache.containsKey(message.getId())) {
mergeDataCache.get(message.getId()).mergeAndFormulaCalculateData(message);
} else {
message.calculateFormula();
mergeDataCache.put(message.getId(), message);
}
mergeDataCache.finishWriting();
......
......@@ -156,7 +156,7 @@ public abstract class AbstractData {
}
@SuppressWarnings("unchecked")
private void calculateFormula() {
public void calculateFormula() {
for (int i = 0; i < stringColumns.length; i++) {
if (nonNull(stringColumns[i].getFormulaOperation())) {
String stringData = (String)stringColumns[i].getFormulaOperation().operate(this);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册