YARN-6253. FlowAcitivityColumnPrefix.store(byte[] rowKey, ...) drops timestamp. Contributed by Haibo Chen.
(cherry picked from commit 34e7c30293b5a56f9f745769a29c5666bdb85d6c)
This commit is contained in:
parent
59d96e247e
commit
6b5b8f090d
|
@ -271,7 +271,7 @@ public enum FlowActivityColumnPrefix
|
|||
byte[] columnQualifier = getColumnPrefixBytes(qualifier);
|
||||
Attribute[] combinedAttributes =
|
||||
HBaseTimelineStorageUtils.combineAttributes(attributes, this.aggOp);
|
||||
column.store(rowKey, tableMutator, columnQualifier, null, inputValue,
|
||||
column.store(rowKey, tableMutator, columnQualifier, timestamp, inputValue,
|
||||
combinedAttributes);
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue