YARN-6874. Supplement timestamp for min start/max end time columns in flow run table to avoid overwrite (Vrushali C via Varun Saxena)
This commit is contained in:
parent
354be99dbf
commit
60765aff9b
|
@ -76,7 +76,7 @@ public enum FlowRunColumn implements Column<FlowRunTable> {
|
||||||
// Future-proof by ensuring the right column prefix hygiene.
|
// Future-proof by ensuring the right column prefix hygiene.
|
||||||
this.columnQualifierBytes = Bytes.toBytes(Separator.SPACE
|
this.columnQualifierBytes = Bytes.toBytes(Separator.SPACE
|
||||||
.encode(columnQualifier));
|
.encode(columnQualifier));
|
||||||
this.column = new ColumnHelper<FlowRunTable>(columnFamily, converter);
|
this.column = new ColumnHelper<FlowRunTable>(columnFamily, converter, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in New Issue