[hop] branch master updated: HOP-3696 PipelineExecutor: NullPointerException when no rows are coming in

[ha...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 1e461be  HOP-3696 PipelineExecutor: NullPointerException when no rows are coming in
     new 4534101  Merge pull request #1286 from sramazzina/HOP-3696
1e461be is described below

commit 1e461bedb7ae749206a54514a645e73c1cd46ec8
Author: Sergio Ramazzina <se...@serasoft.it>
AuthorDate: Fri Jan 21 17:57:47 2022 +0100

    HOP-3696 PipelineExecutor: NullPointerException when no rows are coming in
---
 .../hop/pipeline/transforms/pipelineexecutor/PipelineExecutor.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/transforms/pipelineexecutor/src/main/java/org/apache/hop/pipeline/transforms/pipelineexecutor/PipelineExecutor.java b/plugins/transforms/pipelineexecutor/src/main/java/org/apache/hop/pipeline/transforms/pipelineexecutor/PipelineExecutor.java
index 1aec847..e3ba0cc 100644
--- a/plugins/transforms/pipelineexecutor/src/main/java/org/apache/hop/pipeline/transforms/pipelineexecutor/PipelineExecutor.java
+++ b/plugins/transforms/pipelineexecutor/src/main/java/org/apache/hop/pipeline/transforms/pipelineexecutor/PipelineExecutor.java
@@ -209,9 +209,10 @@ public class PipelineExecutor extends BaseTransform<PipelineExecutorMeta, Pipeli
   }
 
   private void executePipeline(List<String> incomingFieldValues) throws HopException {
+
     PipelineExecutorData pipelineExecutorData = getData();
     // If we got 0 rows on input we don't really want to execute the pipeline
-    if (pipelineExecutorData.groupBuffer.isEmpty()) {
+    if (pipelineExecutorData.groupBuffer == null || pipelineExecutorData.groupBuffer.isEmpty()) {
       return;
     }
     pipelineExecutorData.groupTimeStart = System.currentTimeMillis();