This is an automated email from the ASF dual-hosted git repository. jackie pushed a commit to branch hotfix_time_conversion in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 3989cfdbd892f55da8c20ead9619e32dd15b7ff2 Author: Xiaotian (Jackie) Jiang <[email protected]> AuthorDate: Wed Nov 14 17:14:07 2018 -0800 Hotfix for realtime time conversion when incoming and outgoing time column name are the same --- .../pinot/core/data/recordtransformer/TimeTransformer.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/TimeTransformer.java b/pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/TimeTransformer.java index 2ee8e00..059a739 100644 --- a/pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/TimeTransformer.java +++ b/pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/TimeTransformer.java @@ -55,10 +55,9 @@ public class TimeTransformer implements RecordTransformer { if (_timeConverter == null) { return record; } - // Skip transformation if outgoing value already exist - // NOTE: outgoing value might already exist for OFFLINE data - if (record.getValue(_outgoingTimeColumn) == null) { - record.putField(_outgoingTimeColumn, _timeConverter.convert(record.getValue(_incomingTimeColumn))); + Object incomingValue = record.getValue(_incomingTimeColumn); + if (incomingValue != null) { + record.putField(_outgoingTimeColumn, _timeConverter.convert(incomingValue)); } return record; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
