(pinot) branch master updated: modify TimeValidationTransformer to mark rows as invalid in case primary time column is invalid (#11907)

[jackie]

This is an automated email from the ASF dual-hosted git repository.

jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new c97cff3823 modify TimeValidationTransformer to mark rows as invalid in 
case primary time column is invalid (#11907)
c97cff3823 is described below

commit c97cff3823290abe4e90f3327f6bd3e91d942deb
Author: Gonzalo Ortiz Jaureguizar <gor...@users.noreply.github.com>
AuthorDate: Tue Oct 31 00:20:48 2023 +0100

    modify TimeValidationTransformer to mark rows as invalid in case primary 
time column is invalid (#11907)
---
 .../pinot/segment/local/recordtransformer/TimeValidationTransformer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/TimeValidationTransformer.java
 
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/TimeValidationTransformer.java
index 14917553f3..9a8cd26c2d 100644
--- 
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/TimeValidationTransformer.java
+++ 
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/TimeValidationTransformer.java
@@ -103,6 +103,7 @@ public class TimeValidationTransformer implements 
RecordTransformer {
       if (_continueOnError) {
         LOGGER.debug(errorMessage);
         record.putValue(_timeColumnName, null);
+        record.putValue(GenericRow.INCOMPLETE_RECORD_KEY, true);
         return record;
       } else {
         throw new IllegalStateException(errorMessage);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org