[incubator-hop] branch master updated: [FIX] Subpipeline specified by using variables: messages in the log do not display the correct path to the subpipeline because variables are not resolved.

[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/incubator-hop.git


The following commit(s) were added to refs/heads/master by this push:
     new caa5497  [FIX] Subpipeline specified by using variables: messages in the log do not display the correct path to the subpipeline because variables are not resolved.
     new 5514fca  Merge pull request #1063 from sramazzina/SANDBOX
caa5497 is described below

commit caa5497a31caadb77d7c10643e232c424d4ea808
Author: sergio.ramazzina <se...@serasoft.it>
AuthorDate: Wed Sep 15 13:02:52 2021 +0200

    [FIX] Subpipeline specified by using variables: messages in the log do not display the correct path to the subpipeline because variables are not resolved.
---
 .../hop/pipeline/transforms/kafka/consumer/KafkaConsumerInput.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/transforms/kafka/src/main/java/org/apache/hop/pipeline/transforms/kafka/consumer/KafkaConsumerInput.java b/plugins/transforms/kafka/src/main/java/org/apache/hop/pipeline/transforms/kafka/consumer/KafkaConsumerInput.java
index f5090d7..79f1921 100644
--- a/plugins/transforms/kafka/src/main/java/org/apache/hop/pipeline/transforms/kafka/consumer/KafkaConsumerInput.java
+++ b/plugins/transforms/kafka/src/main/java/org/apache/hop/pipeline/transforms/kafka/consumer/KafkaConsumerInput.java
@@ -100,7 +100,7 @@ public class KafkaConsumerInput
       String realFilename = resolve(meta.getFilename());
       PipelineMeta subTransMeta = new PipelineMeta(realFilename, metadataProvider, true, this);
       subTransMeta.setMetadataProvider(metadataProvider);
-      subTransMeta.setFilename(meta.getFilename());
+      subTransMeta.setFilename(realFilename);
       subTransMeta.setPipelineType(PipelineMeta.PipelineType.SingleThreaded);
       logDetailed("Loaded sub-pipeline '" + realFilename + "'");