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 d76bd27451 Handle null values encountered in
CLPDecodeTransformFunction (#14364)
d76bd27451 is described below
commit d76bd2745192d524eb6444cbf25ff41d691af97c
Author: Jack Luo <[email protected]>
AuthorDate: Mon Nov 4 15:38:04 2024 +0800
Handle null values encountered in CLPDecodeTransformFunction (#14364)
---
.../core/operator/transform/function/CLPDecodeTransformFunction.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/CLPDecodeTransformFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/CLPDecodeTransformFunction.java
index bf2eb79cd7..6b1945e533 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/CLPDecodeTransformFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/CLPDecodeTransformFunction.java
@@ -120,7 +120,10 @@ public class CLPDecodeTransformFunction extends
BaseTransformFunction {
BuiltInVariableHandlingRuleVersions.VariableEncodingMethodsV1);
for (int i = 0; i < length; i++) {
try {
- _stringValuesSV[i] = clpMessageDecoder.decodeMessage(logtypes[i],
dictionaryVars[i], encodedVars[i]);
+ // The current CLP decoder implementation expects at least the logtype
to be non-null
+ // as it does not support null value messages
+ _stringValuesSV[i] = (null == logtypes[i]) ? null
+ : clpMessageDecoder.decodeMessage(logtypes[i], dictionaryVars[i],
encodedVars[i]);
} catch (Exception ex) {
_logger.error("Failed to decode CLP-encoded field.", ex);
_stringValuesSV[i] = _defaultValue;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
