88import io .logz .sawmill .exceptions .ProcessorExecutionException ;
99import io .logz .sawmill .utilities .JsonUtils ;
1010import org .apache .commons .collections4 .CollectionUtils ;
11+ import org .slf4j .Logger ;
12+ import org .slf4j .LoggerFactory ;
1113
14+ import java .util .Arrays ;
1215import java .util .HashSet ;
1316import java .util .List ;
1417import java .util .Map ;
1720
1821@ ProcessorProvider (type = "addSignature" , factory = AddSignatureProcessor .Factory .class )
1922public class AddSignatureProcessor implements Processor {
23+ private final static Logger logger = LoggerFactory .getLogger (AddSignatureProcessor .class );
2024 private final SignatureMode signatureMode ;
2125 private final String signatureFieldName ;
2226 private final Set <String > includeValueFields ;
@@ -32,12 +36,14 @@ public ProcessResult process(Doc doc) throws InterruptedException {
3236 try {
3337 signature = createSignature (doc );
3438 } catch (Exception e ) {
35- return ProcessResult .failure (
36- "failed to create signature, SignatureMode: " + signatureMode ,
39+ String errorMessage = "failed to create signature, SignatureMode: " + signatureMode ;
40+ logger .debug (errorMessage , e );
41+ return ProcessResult .failure (errorMessage ,
3742 new ProcessorExecutionException (AddSignatureProcessor .class .getSimpleName (), e ));
3843 }
3944
4045 if (signature == 0 ) {
46+ logger .debug ("signature collection is empty, SignatureMode: " + signatureMode );
4147 if (signatureMode .equals (SignatureMode .FIELDS_NAMES ) || signatureMode .equals (SignatureMode .HYBRID )) {
4248 return ProcessResult .failure ("failed to extract fields names, SignatureMode: " + signatureMode );
4349 }
0 commit comments