This is an automated email from the ASF dual-hosted git repository.
nadment pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/hop.git
The following commit(s) were added to refs/heads/main by this push:
new b97fa1bfb7 Fix for issue #7342 (#7358)
b97fa1bfb7 is described below
commit b97fa1bfb751dc610ce63eec1e6e0cabb130d38d
Author: Matt Casters <[email protected]>
AuthorDate: Fri Jun 26 23:13:53 2026 +0200
Fix for issue #7342 (#7358)
* Fix for issue #7342
* Fix for issue #7342 : more code hardening and integration test
* issue #7342 : RAT
---
.../apache/hop/execution/IExecutionSelector.java | 58 +++
.../caching/BaseCachingExecutionInfoLocation.java | 18 +-
.../caching/CachingFileExecutionInfoLocation.java | 9 +-
.../exec-info/001-caching-file-location-basic.hpl | 111 +++++
.../001-caching-file-location-validation.hpl | 483 +++++++++++++++++++++
integration-tests/exec-info/dev-env-config.json | 9 +
integration-tests/exec-info/hop-config.json | 59 +++
.../main-001-caching-file-location-basic.hwf | 138 ++++++
.../execution-data-profile/first-last.json | 16 +
.../execution-info-location/caching-file.json | 13 +
.../local-caching-file.json | 22 +
.../metadata/pipeline-run-configuration/local.json | 20 +
.../local-caching-file.json | 12 +
.../metadata/workflow-run-configuration/local.json | 11 +
integration-tests/exec-info/project-config.json | 13 +
.../hop/pipeline/transforms/execinfo/ExecInfo.java | 2 +-
16 files changed, 983 insertions(+), 11 deletions(-)
diff --git
a/engine/src/main/java/org/apache/hop/execution/IExecutionSelector.java
b/engine/src/main/java/org/apache/hop/execution/IExecutionSelector.java
index bf5b1278cd..4772f36000 100644
--- a/engine/src/main/java/org/apache/hop/execution/IExecutionSelector.java
+++ b/engine/src/main/java/org/apache/hop/execution/IExecutionSelector.java
@@ -55,4 +55,62 @@ public interface IExecutionSelector {
* @return True if the filter string is a UUID.
*/
boolean isSelectingByUuid();
+
+ static final IExecutionSelector ALL =
+ new IExecutionSelector() {
+ @Override
+ public boolean isSelectingParents() {
+ return false;
+ }
+
+ @Override
+ public boolean isSelectingFailed() {
+ return false;
+ }
+
+ @Override
+ public boolean isSelectingRunning() {
+ return false;
+ }
+
+ @Override
+ public boolean isSelectingFinished() {
+ return false;
+ }
+
+ @Override
+ public boolean isSelectingPipelines() {
+ return false;
+ }
+
+ @Override
+ public boolean isSelectingWorkflows() {
+ return false;
+ }
+
+ @Override
+ public String filterText() {
+ return null;
+ }
+
+ @Override
+ public LastPeriod startDateFilter() {
+ return null;
+ }
+
+ @Override
+ public boolean isSelected(Execution execution) {
+ return true;
+ }
+
+ @Override
+ public boolean isSelected(ExecutionState executionState) {
+ return true;
+ }
+
+ @Override
+ public boolean isSelectingByUuid() {
+ return false;
+ }
+ };
}
diff --git
a/engine/src/main/java/org/apache/hop/execution/caching/BaseCachingExecutionInfoLocation.java
b/engine/src/main/java/org/apache/hop/execution/caching/BaseCachingExecutionInfoLocation.java
index 03edced4ec..77fb89ebbe 100644
---
a/engine/src/main/java/org/apache/hop/execution/caching/BaseCachingExecutionInfoLocation.java
+++
b/engine/src/main/java/org/apache/hop/execution/caching/BaseCachingExecutionInfoLocation.java
@@ -229,7 +229,7 @@ public abstract class BaseCachingExecutionInfoLocation
implements IExecutionInfo
// Get all the IDs from disk if we don't have it in the cache.
//
- retrieveIds(includeChildren, ids, limit, null);
+ retrieveIds(includeChildren, ids, limit, IExecutionSelector.ALL);
// Reverse sort the IDs by date
//
@@ -254,12 +254,13 @@ public abstract class BaseCachingExecutionInfoLocation
implements IExecutionInfo
@Override
public List<String> findExecutionIDs(IExecutionSelector selector) throws
HopException {
+ final IExecutionSelector activeSelector = selector == null ?
IExecutionSelector.ALL : selector;
Set<DatedId> dateIds = new HashSet<>();
- if (selector.isSelectingByUuid()) {
+ if (activeSelector.isSelectingByUuid()) {
// We try the cache and simply loading the file itself by ID.
//
- CacheEntry cacheEntry = loadCacheEntry(selector.filterText());
+ CacheEntry cacheEntry = loadCacheEntry(activeSelector.filterText());
if (cacheEntry != null) {
return List.of(cacheEntry.getId());
}
@@ -267,11 +268,11 @@ public abstract class BaseCachingExecutionInfoLocation
implements IExecutionInfo
// The data in the cache is the most recent, so we start with that.
//
- getExecutionIdsFromCache(dateIds, selector);
+ getExecutionIdsFromCache(dateIds, activeSelector);
// Get all the IDs from disk if we don't have it in the cache.
//
- retrieveIds(!selector.isSelectingParents(), dateIds, 50, selector);
+ retrieveIds(!activeSelector.isSelectingParents(), dateIds, 50,
activeSelector);
// Reverse sort the IDs by date
//
@@ -475,7 +476,12 @@ public abstract class BaseCachingExecutionInfoLocation
implements IExecutionInfo
protected static void addChildIds(CacheEntry entry, Set<DatedId> ids) {
for (String childId : entry.getChildIds()) {
Execution childExecution = entry.getChildExecution(childId);
- ids.add(new DatedId(childExecution.getId(),
childExecution.getRegistrationDate()));
+ // We're only interested to know about pipelines and workflows here.
+ //
+ if (childExecution.getExecutionType() == ExecutionType.Pipeline
+ || childExecution.getExecutionType() == ExecutionType.Workflow) {
+ ids.add(new DatedId(childExecution.getId(),
childExecution.getRegistrationDate()));
+ }
}
}
diff --git
a/engine/src/main/java/org/apache/hop/execution/caching/CachingFileExecutionInfoLocation.java
b/engine/src/main/java/org/apache/hop/execution/caching/CachingFileExecutionInfoLocation.java
index 2120533906..eb890a49e8 100644
---
a/engine/src/main/java/org/apache/hop/execution/caching/CachingFileExecutionInfoLocation.java
+++
b/engine/src/main/java/org/apache/hop/execution/caching/CachingFileExecutionInfoLocation.java
@@ -120,7 +120,7 @@ public class CachingFileExecutionInfoLocation extends
BaseCachingExecutionInfoLo
try {
CacheEntry entry = new CacheEntry();
entry.setId(executionId);
- String filename = entry.calculateFilename(rootFolder);
+ String filename = entry.calculateFilename(actualRootFolder);
if (!HopVfs.fileExists(filename)) {
return null;
}
@@ -137,6 +137,7 @@ public class CachingFileExecutionInfoLocation extends
BaseCachingExecutionInfoLo
protected void retrieveIds(
boolean includeChildren, Set<DatedId> ids, int limit, final
IExecutionSelector selector)
throws HopException {
+ final IExecutionSelector activeSelector = selector == null ?
IExecutionSelector.ALL : selector;
try {
FileObject[] files = getAllFileObjects(actualRootFolder);
@@ -146,7 +147,7 @@ public class CachingFileExecutionInfoLocation extends
BaseCachingExecutionInfoLo
// We do a first filtering on the modification date
// This is probably the execution end date, so we add an hour.
//
- LastPeriod dateFilter = selector.startDateFilter();
+ LastPeriod dateFilter = activeSelector.startDateFilter();
if (dateFilter != null) {
LocalDateTime roughStartDate =
dateFilter.calculateStartDate().minusHours(1);
long startDate =
@@ -165,10 +166,10 @@ public class CachingFileExecutionInfoLocation extends
BaseCachingExecutionInfoLo
// Not much loaded from disk or cache
continue;
}
- if (!selector.isSelected(entry.getExecution())) {
+ if (!activeSelector.isSelected(entry.getExecution())) {
continue;
}
- if (!selector.isSelected(entry.getExecutionState())) {
+ if (!activeSelector.isSelected(entry.getExecutionState())) {
continue;
}
diff --git a/integration-tests/exec-info/001-caching-file-location-basic.hpl
b/integration-tests/exec-info/001-caching-file-location-basic.hpl
new file mode 100644
index 0000000000..378065d2aa
--- /dev/null
+++ b/integration-tests/exec-info/001-caching-file-location-basic.hpl
@@ -0,0 +1,111 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+-->
+<pipeline>
+ <info>
+ <capture_transform_performance>N</capture_transform_performance>
+
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
+
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
+ <pipeline_type>Normal</pipeline_type>
+ <pipeline_status>-1</pipeline_status>
+ <parameters/>
+ <name>New pipeline</name>
+ <name_sync_with_filename>Y</name_sync_with_filename>
+ <created_user>-</created_user>
+ <modified_user>-</modified_user>
+ <created_date>2026/06/26 17:43:23.585</created_date>
+ <modified_date>2026/06/26 17:43:23.585</modified_date>
+ </info>
+ <transform>
+ <type>RowGenerator</type>
+ <name>250</name>
+ <never_ending>N</never_ending>
+ <interval_in_ms>5000</interval_in_ms>
+ <row_time_field>now</row_time_field>
+ <last_time_field>FiveSecondsAgo</last_time_field>
+ <limit>250</limit>
+ <fields/>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>160</xloc>
+ <yloc>80</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>Sequence</type>
+ <name>id</name>
+ <valuename>id</valuename>
+ <use_database>N</use_database>
+ <connection/>
+ <schema/>
+ <seqname>SEQ_</seqname>
+ <use_counter>Y</use_counter>
+ <counter_name/>
+ <start_at>10000</start_at>
+ <increment_by>1</increment_by>
+ <max_value>999999999</max_value>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>256</xloc>
+ <yloc>80</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>Dummy</type>
+ <name>result</name>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>352</xloc>
+ <yloc>80</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <order>
+ <hop>
+ <from>250</from>
+ <to>id</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>id</from>
+ <to>result</to>
+ <enabled>Y</enabled>
+ </hop>
+ </order>
+ <notepads/>
+ <attributes/>
+ <transform_error_handling/>
+</pipeline>
diff --git
a/integration-tests/exec-info/001-caching-file-location-validation.hpl
b/integration-tests/exec-info/001-caching-file-location-validation.hpl
new file mode 100644
index 0000000000..70e3ca0a32
--- /dev/null
+++ b/integration-tests/exec-info/001-caching-file-location-validation.hpl
@@ -0,0 +1,483 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+-->
+<pipeline>
+ <info>
+ <capture_transform_performance>N</capture_transform_performance>
+
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
+
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
+ <pipeline_type>Normal</pipeline_type>
+ <pipeline_status>-1</pipeline_status>
+ <parameters/>
+ <name>New pipeline</name>
+ <name_sync_with_filename>Y</name_sync_with_filename>
+ <created_user>-</created_user>
+ <modified_user>-</modified_user>
+ <created_date>2026/06/26 18:15:01.687</created_date>
+ <modified_date>2026/06/26 18:15:01.687</modified_date>
+ </info>
+ <transform>
+ <type>ExecInfo</type>
+ <name>Find last execution</name>
+ <location>caching-file</location>
+ <operationType>FindLastExecution</operationType>
+ <idFieldName/>
+ <parentIdFieldName/>
+ <typeFieldName>type</typeFieldName>
+ <nameFieldName>name</nameFieldName>
+ <includeChildrenFieldName/>
+ <limitFieldName/>
+ <distribute>N</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>224</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>DataGrid</type>
+ <name>Data grid</name>
+ <fields>
+ <field>
+ <currency/>
+ <decimal/>
+ <group/>
+ <name>name</name>
+ <type>String</type>
+ <format/>
+ <length>-1</length>
+ <precision>-1</precision>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ <field>
+ <currency/>
+ <decimal/>
+ <group/>
+ <name>type</name>
+ <type>String</type>
+ <format/>
+ <length>-1</length>
+ <precision>-1</precision>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ </fields>
+ <data>
+ <line>
+ <item>001-caching-file-location-basic</item>
+ <item>Pipeline</item>
+ </line>
+ </data>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>96</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>SelectValues</type>
+ <name>remove big fields</name>
+ <fields>
+ <select_unspecified>N</select_unspecified>
+ <remove>
+ <name>executorXml</name>
+ </remove>
+ <remove>
+ <name>metadataJson</name>
+ </remove>
+ <remove>
+ <name>loggingText</name>
+ </remove>
+ </fields>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>352</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>Calculator</type>
+ <name>now minus 1 minute</name>
+ <calculation>
+ <field_name>one</field_name>
+ <calc_type>CONSTANT</calc_type>
+ <field_a>-1</field_a>
+ <field_b/>
+ <field_c/>
+ <value_type>Integer</value_type>
+ <value_length>-1</value_length>
+ <value_precision>-1</value_precision>
+ <conversion_mask/>
+ <decimal_symbol/>
+ <grouping_symbol/>
+ <currency_symbol/>
+ <remove>N</remove>
+ </calculation>
+ <calculation>
+ <field_name>now-1</field_name>
+ <calc_type>ADD_MINUTES</calc_type>
+ <field_a>now</field_a>
+ <field_b>one</field_b>
+ <field_c/>
+ <value_type>Date</value_type>
+ <value_length>-1</value_length>
+ <value_precision>-1</value_precision>
+ <conversion_mask/>
+ <decimal_symbol/>
+ <grouping_symbol/>
+ <currency_symbol/>
+ <remove>N</remove>
+ </calculation>
+ <failIfNoFile>Y</failIfNoFile>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>592</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>SystemInfo</type>
+ <name>now</name>
+ <fields>
+ <field>
+ <name>now</name>
+ <type>system date (variable)</type>
+ </field>
+ </fields>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>464</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>FilterRows</type>
+ <name>start > T-1 minute?</name>
+ <compare>
+ <condition>
+ <negated>N</negated>
+ <operator>-</operator>
+ <leftvalue>executionStartDate</leftvalue>
+ <function><</function>
+ <rightvalue>now-1</rightvalue>
+ <conditions/>
+ </condition>
+ </compare>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>736</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>Abort</type>
+ <name>Abort</name>
+ <row_threshold>0</row_threshold>
+ <message/>
+ <always_log_rows>Y</always_log_rows>
+ <abort_option>ABORT_WITH_ERROR</abort_option>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>864</xloc>
+ <yloc>112</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>GroupBy</type>
+ <name>count rows</name>
+ <all_rows>N</all_rows>
+ <directory>${java.io.tmpdir}</directory>
+ <prefix>grp</prefix>
+ <ignore_aggregate>N</ignore_aggregate>
+ <group/>
+ <fields>
+ <field>
+ <aggregate>count</aggregate>
+ <subject/>
+ <type>COUNT_ANY</type>
+ <valuefield/>
+ </field>
+ </fields>
+ <add_linenr>N</add_linenr>
+ <linenr_fieldname/>
+ <give_back_row>Y</give_back_row>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>352</xloc>
+ <yloc>224</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>FilterRows</type>
+ <name>Not 1 row?</name>
+ <compare>
+ <condition>
+ <negated>N</negated>
+ <operator>-</operator>
+ <leftvalue>count</leftvalue>
+ <function><></function>
+ <value>
+ <name>constant</name>
+ <type>Integer</type>
+ <text>1</text>
+ <length>-1</length>
+ <precision>0</precision>
+ <isnull>N</isnull>
+ <mask>####0;-####0</mask>
+ </value>
+ <conditions/>
+ </condition>
+ </compare>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>464</xloc>
+ <yloc>224</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>Abort</type>
+ <name>Last exec not found</name>
+ <row_threshold>0</row_threshold>
+ <message>Last exec not found</message>
+ <always_log_rows>Y</always_log_rows>
+ <abort_option>ABORT_WITH_ERROR</abort_option>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>592</xloc>
+ <yloc>224</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <transform>
+ <type>ScriptValueMod</type>
+ <name>Throw error if one field is null</name>
+ <jsScripts>
+ <jsScript>
+ <jsScript_type>0</jsScript_type>
+ <jsScript_name>Script 1</jsScript_name>
+ <jsScript_script>var ok = name != null
+ && type != null
+ && executionId != null
+ && filename != null
+ && executorXml != null
+ && metadataJson != null
+ && registrationDate != null
+ && executionStartDate != null
+ && runConfigurationName != null
+ && logLevel != null
+ && updateTime != null
+ && loggingText != null
+ && failed != null
+ && statusDescription != null
+ && executionEndDate != null;
+
+if (!ok) {
+ throw "One or more fields didn't have values"
+}
+</jsScript_script>
+ </jsScript>
+ </jsScripts>
+ <fields/>
+ <optimizationLevel>9</optimizationLevel>
+ <distribute>Y</distribute>
+ <copies>1</copies>
+ <GUI>
+ <xloc>352</xloc>
+ <yloc>336</yloc>
+ </GUI>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <attributes/>
+ </transform>
+ <order>
+ <hop>
+ <from>Data grid</from>
+ <to>Find last execution</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Find last execution</from>
+ <to>remove big fields</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>remove big fields</from>
+ <to>now</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>now</from>
+ <to>now minus 1 minute</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>now minus 1 minute</from>
+ <to>start > T-1 minute?</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>start > T-1 minute?</from>
+ <to>Abort</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Find last execution</from>
+ <to>count rows</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>count rows</from>
+ <to>Not 1 row?</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Not 1 row?</from>
+ <to>Last exec not found</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Find last execution</from>
+ <to>Throw error if one field is null</to>
+ <enabled>Y</enabled>
+ </hop>
+ </order>
+ <notepads>
+ <notepad>
+ <note>The last execution needs to be less than 1 minute ago.</note>
+ <fontname>Noto Sans</fontname>
+ <fontsize>10</fontsize>
+ <fontbold>N</fontbold>
+ <fontitalic>N</fontitalic>
+ <fontcolorred>200</fontcolorred>
+ <fontcolorgreen>231</fontcolorgreen>
+ <fontcolorblue>250</fontcolorblue>
+ <backgroundcolorred>15</backgroundcolorred>
+ <backgroundcolorgreen>136</backgroundcolorgreen>
+ <backgroundcolorblue>210</backgroundcolorblue>
+ <bordercolorred>200</bordercolorred>
+ <bordercolorgreen>231</bordercolorgreen>
+ <bordercolorblue>250</bordercolorblue>
+ <xloc>544</xloc>
+ <yloc>64</yloc>
+ <width>32</width>
+ <height>32</height>
+ </notepad>
+ <notepad>
+ <note>We need one row as a result</note>
+ <fontname>Noto Sans</fontname>
+ <fontsize>10</fontsize>
+ <fontbold>N</fontbold>
+ <fontitalic>N</fontitalic>
+ <fontcolorred>200</fontcolorred>
+ <fontcolorgreen>231</fontcolorgreen>
+ <fontcolorblue>250</fontcolorblue>
+ <backgroundcolorred>15</backgroundcolorred>
+ <backgroundcolorgreen>136</backgroundcolorgreen>
+ <backgroundcolorblue>210</backgroundcolorblue>
+ <bordercolorred>200</bordercolorred>
+ <bordercolorgreen>231</bordercolorgreen>
+ <bordercolorblue>250</bordercolorblue>
+ <xloc>128</xloc>
+ <yloc>224</yloc>
+ <width>32</width>
+ <height>32</height>
+ </notepad>
+ <notepad>
+ <note>The fields need to have actual values</note>
+ <fontname>Noto Sans</fontname>
+ <fontsize>10</fontsize>
+ <fontbold>N</fontbold>
+ <fontitalic>N</fontitalic>
+ <fontcolorred>200</fontcolorred>
+ <fontcolorgreen>231</fontcolorgreen>
+ <fontcolorblue>250</fontcolorblue>
+ <backgroundcolorred>15</backgroundcolorred>
+ <backgroundcolorgreen>136</backgroundcolorgreen>
+ <backgroundcolorblue>210</backgroundcolorblue>
+ <bordercolorred>200</bordercolorred>
+ <bordercolorgreen>231</bordercolorgreen>
+ <bordercolorblue>250</bordercolorblue>
+ <xloc>128</xloc>
+ <yloc>336</yloc>
+ <width>32</width>
+ <height>32</height>
+ </notepad>
+ </notepads>
+ <attributes/>
+ <transform_error_handling/>
+</pipeline>
diff --git a/integration-tests/exec-info/dev-env-config.json
b/integration-tests/exec-info/dev-env-config.json
new file mode 100644
index 0000000000..2470eb7b94
--- /dev/null
+++ b/integration-tests/exec-info/dev-env-config.json
@@ -0,0 +1,9 @@
+{
+ "variables" : [
+ {
+ "name" : "CACHING_FILE_LOCATION",
+ "value" : "/tmp/caching-file-location",
+ "description" : "The location of the caching file location"
+ }
+ ]
+}
\ No newline at end of file
diff --git a/integration-tests/exec-info/hop-config.json
b/integration-tests/exec-info/hop-config.json
new file mode 100644
index 0000000000..1aa118f6ec
--- /dev/null
+++ b/integration-tests/exec-info/hop-config.json
@@ -0,0 +1,59 @@
+{
+ "variables": [],
+ "LocaleDefault": "en_BE",
+ "guiProperties": {
+ "FontFixedSize": "13",
+ "MaxUndo": "100",
+ "DarkMode": "Y",
+ "FontNoteSize": "13",
+ "ShowOSLook": "Y",
+ "FontFixedStyle": "0",
+ "FontNoteName": ".AppleSystemUIFont",
+ "FontFixedName": "Monospaced",
+ "FontGraphStyle": "0",
+ "FontDefaultSize": "13",
+ "GraphColorR": "255",
+ "FontGraphSize": "13",
+ "IconSize": "32",
+ "BackgroundColorB": "255",
+ "FontNoteStyle": "0",
+ "FontGraphName": ".AppleSystemUIFont",
+ "FontDefaultName": ".AppleSystemUIFont",
+ "GraphColorG": "255",
+ "UseGlobalFileBookmarks": "Y",
+ "FontDefaultStyle": "0",
+ "GraphColorB": "255",
+ "BackgroundColorR": "255",
+ "BackgroundColorG": "255",
+ "WorkflowDialogStyle": "RESIZE,MAX,MIN",
+ "LineWidth": "1",
+ "ContextDialogShowCategories": "Y"
+ },
+ "projectsConfig": {
+ "enabled": true,
+ "projectMandatory": true,
+ "environmentMandatory": false,
+ "defaultProject": "default",
+ "defaultEnvironment": null,
+ "standardParentProject": "default",
+ "standardProjectsFolder": null,
+ "projectConfigurations": [
+ {
+ "projectName": "default",
+ "projectHome": "${HOP_CONFIG_FOLDER}",
+ "configFilename": "project-config.json"
+ }
+ ],
+ "lifecycleEnvironments": [
+ {
+ "name": "dev",
+ "purpose": "Testing",
+ "projectName": "default",
+ "configurationFiles": [
+ "${PROJECT_HOME}/dev-env-config.json"
+ ]
+ }
+ ],
+ "projectLifecycles": []
+ }
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/main-001-caching-file-location-basic.hwf
b/integration-tests/exec-info/main-001-caching-file-location-basic.hwf
new file mode 100644
index 0000000000..6ca3dc1989
--- /dev/null
+++ b/integration-tests/exec-info/main-001-caching-file-location-basic.hwf
@@ -0,0 +1,138 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+-->
+<workflow>
+ <name>New workflow</name>
+ <name_sync_with_filename>Y</name_sync_with_filename>
+ <created_user>-</created_user>
+ <modified_user>-</modified_user>
+ <created_date>2026/06/26 17:42:49.284</created_date>
+ <modified_date>2026/06/26 17:42:49.284</modified_date>
+ <parameters/>
+ <actions>
+ <action>
+ <repeat>N</repeat>
+ <schedulerType>0</schedulerType>
+ <intervalSeconds>0</intervalSeconds>
+ <intervalMinutes>60</intervalMinutes>
+ <DayOfMonth>1</DayOfMonth>
+ <weekDay>1</weekDay>
+ <minutes>0</minutes>
+ <hour>12</hour>
+ <doNotWaitOnFirstExecution>N</doNotWaitOnFirstExecution>
+ <name>Start</name>
+ <description/>
+ <type>SPECIAL</type>
+ <attributes/>
+ <xloc>80</xloc>
+ <yloc>80</yloc>
+ <parallel>N</parallel>
+ <attributes_hac/>
+ </action>
+ <action>
+ <filename>${PROJECT_HOME}/001-caching-file-location-basic.hpl</filename>
+ <params_from_previous>N</params_from_previous>
+ <exec_per_row>N</exec_per_row>
+ <clear_rows>N</clear_rows>
+ <clear_files>N</clear_files>
+ <create_parent_folder>N</create_parent_folder>
+ <set_logfile>N</set_logfile>
+ <set_append_logfile>N</set_append_logfile>
+ <add_date>N</add_date>
+ <add_time>N</add_time>
+ <loglevel>Basic</loglevel>
+ <wait_until_finished>Y</wait_until_finished>
+ <parameters>
+ <pass_all_parameters>Y</pass_all_parameters>
+ </parameters>
+ <run_configuration>local-caching-file</run_configuration>
+ <name>001-caching-file-location-basic</name>
+ <description/>
+ <type>PIPELINE</type>
+ <attributes/>
+ <xloc>512</xloc>
+ <yloc>80</yloc>
+ <parallel>N</parallel>
+ <attributes_hac/>
+ </action>
+ <action>
+ <foldername>${java.io.tmpdir}/caching-file-location/</foldername>
+ <fail_of_folder_exists>N</fail_of_folder_exists>
+ <name>create /tmp/caching-file-location/</name>
+ <description/>
+ <type>CREATE_FOLDER</type>
+ <attributes/>
+ <xloc>272</xloc>
+ <yloc>80</yloc>
+ <parallel>N</parallel>
+ <attributes_hac/>
+ </action>
+ <action>
+
<filename>${PROJECT_HOME}/001-caching-file-location-validation.hpl</filename>
+ <params_from_previous>N</params_from_previous>
+ <exec_per_row>N</exec_per_row>
+ <clear_rows>N</clear_rows>
+ <clear_files>N</clear_files>
+ <create_parent_folder>N</create_parent_folder>
+ <set_logfile>N</set_logfile>
+ <set_append_logfile>N</set_append_logfile>
+ <add_date>N</add_date>
+ <add_time>N</add_time>
+ <loglevel>Basic</loglevel>
+ <wait_until_finished>Y</wait_until_finished>
+ <parameters>
+ <pass_all_parameters>Y</pass_all_parameters>
+ </parameters>
+ <run_configuration>local</run_configuration>
+ <name>001-caching-file-location-validation</name>
+ <description/>
+ <type>PIPELINE</type>
+ <attributes/>
+ <xloc>784</xloc>
+ <yloc>80</yloc>
+ <parallel>N</parallel>
+ <attributes_hac/>
+ </action>
+ </actions>
+ <hops>
+ <hop>
+ <from>Start</from>
+ <to>create /tmp/caching-file-location/</to>
+ <evaluation>Y</evaluation>
+ <unconditional>Y</unconditional>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>create /tmp/caching-file-location/</from>
+ <to>001-caching-file-location-basic</to>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>001-caching-file-location-basic</from>
+ <to>001-caching-file-location-validation</to>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ <enabled>Y</enabled>
+ </hop>
+ </hops>
+ <notepads/>
+ <attributes/>
+</workflow>
diff --git
a/integration-tests/exec-info/metadata/execution-data-profile/first-last.json
b/integration-tests/exec-info/metadata/execution-data-profile/first-last.json
new file mode 100644
index 0000000000..dc221af474
--- /dev/null
+++
b/integration-tests/exec-info/metadata/execution-data-profile/first-last.json
@@ -0,0 +1,16 @@
+{
+ "name": "first-last",
+ "description": "",
+ "sampler": [
+ {
+ "FirstRowsExecutionDataSampler": {
+ "sampleSize": "100"
+ }
+ },
+ {
+ "LastRowsExecutionDataSampler": {
+ "sampleSize": "100"
+ }
+ }
+ ]
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/metadata/execution-info-location/caching-file.json
b/integration-tests/exec-info/metadata/execution-info-location/caching-file.json
new file mode 100644
index 0000000000..608afecb39
--- /dev/null
+++
b/integration-tests/exec-info/metadata/execution-info-location/caching-file.json
@@ -0,0 +1,13 @@
+{
+ "executionInfoLocation": {
+ "caching-file-location": {
+ "persistenceDelay": "5000",
+ "rootFolder": "${CACHING_FILE_LOCATION}",
+ "maxCacheAge": "86400000"
+ }
+ },
+ "dataLoggingDelay": "2000",
+ "name": "caching-file",
+ "description": "",
+ "dataLoggingInterval": "5000"
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/metadata/pipeline-run-configuration/local-caching-file.json
b/integration-tests/exec-info/metadata/pipeline-run-configuration/local-caching-file.json
new file mode 100644
index 0000000000..0b03a5ee64
--- /dev/null
+++
b/integration-tests/exec-info/metadata/pipeline-run-configuration/local-caching-file.json
@@ -0,0 +1,22 @@
+{
+ "engineRunConfiguration": {
+ "Local": {
+ "feedback_size": "50000",
+ "sample_size": "100",
+ "sample_type_in_gui": "Last",
+ "wait_time": "20",
+ "rowset_size": "10000",
+ "safe_mode": false,
+ "show_feedback": false,
+ "topo_sort": false,
+ "gather_metrics": false,
+ "transactional": false
+ }
+ },
+ "defaultSelection": true,
+ "configurationVariables": [],
+ "name": "local-caching-file",
+ "description": "Runs your pipelines locally with the standard local Hop
pipeline engine",
+ "dataProfile": "first-last",
+ "executionInfoLocationName": "caching-file"
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/metadata/pipeline-run-configuration/local.json
b/integration-tests/exec-info/metadata/pipeline-run-configuration/local.json
new file mode 100644
index 0000000000..d6b7ca4eed
--- /dev/null
+++ b/integration-tests/exec-info/metadata/pipeline-run-configuration/local.json
@@ -0,0 +1,20 @@
+{
+ "engineRunConfiguration": {
+ "Local": {
+ "feedback_size": "50000",
+ "sample_size": "100",
+ "sample_type_in_gui": "Last",
+ "wait_time": "20",
+ "rowset_size": "10000",
+ "safe_mode": false,
+ "show_feedback": false,
+ "topo_sort": false,
+ "gather_metrics": false,
+ "transactional": false
+ }
+ },
+ "defaultSelection": true,
+ "configurationVariables": [],
+ "name": "local",
+ "description": "Runs your pipelines locally with the standard local Hop
pipeline engine"
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/metadata/workflow-run-configuration/local-caching-file.json
b/integration-tests/exec-info/metadata/workflow-run-configuration/local-caching-file.json
new file mode 100644
index 0000000000..087336dfcf
--- /dev/null
+++
b/integration-tests/exec-info/metadata/workflow-run-configuration/local-caching-file.json
@@ -0,0 +1,12 @@
+{
+ "engineRunConfiguration": {
+ "Local": {
+ "safe_mode": false,
+ "transactional": false
+ }
+ },
+ "defaultSelection": true,
+ "name": "local-caching-file",
+ "description": "Runs your workflows locally with the standard local Hop
workflow engine",
+ "executionInfoLocationName": "caching-file"
+}
\ No newline at end of file
diff --git
a/integration-tests/exec-info/metadata/workflow-run-configuration/local.json
b/integration-tests/exec-info/metadata/workflow-run-configuration/local.json
new file mode 100644
index 0000000000..1d0cf74bae
--- /dev/null
+++ b/integration-tests/exec-info/metadata/workflow-run-configuration/local.json
@@ -0,0 +1,11 @@
+{
+ "engineRunConfiguration": {
+ "Local": {
+ "safe_mode": false,
+ "transactional": false
+ }
+ },
+ "defaultSelection": true,
+ "name": "local",
+ "description": "Runs your workflows locally with the standard local Hop
workflow engine"
+}
\ No newline at end of file
diff --git a/integration-tests/exec-info/project-config.json
b/integration-tests/exec-info/project-config.json
new file mode 100644
index 0000000000..6a91171e1c
--- /dev/null
+++ b/integration-tests/exec-info/project-config.json
@@ -0,0 +1,13 @@
+{
+ "metadataBaseFolder" : "${PROJECT_HOME}/metadata",
+ "unitTestsBasePath" : "${PROJECT_HOME}",
+ "dataSetsCsvFolder" : "${PROJECT_HOME}/datasets",
+ "enforcingExecutionInHome" : true,
+ "config" : {
+ "variables" : [ {
+ "name" : "HOP_LICENSE_HEADER_FILE",
+ "value" : "${PROJECT_HOME}/../asf-header.txt",
+ "description" : "This will automatically serialize the ASF license
header into pipelines and workflows in the integration test projects"
+ } ]
+ }
+}
\ No newline at end of file
diff --git
a/plugins/transforms/execinfo/src/main/java/org/apache/hop/pipeline/transforms/execinfo/ExecInfo.java
b/plugins/transforms/execinfo/src/main/java/org/apache/hop/pipeline/transforms/execinfo/ExecInfo.java
index 364efc5f03..6e37286ddc 100644
---
a/plugins/transforms/execinfo/src/main/java/org/apache/hop/pipeline/transforms/execinfo/ExecInfo.java
+++
b/plugins/transforms/execinfo/src/main/java/org/apache/hop/pipeline/transforms/execinfo/ExecInfo.java
@@ -316,7 +316,7 @@ public class ExecInfo extends BaseTransform<ExecInfoMeta,
ExecInfoData> {
}
private String getValueName(IRowMeta rowMeta, Object[] row) throws
HopException {
- String nameField = resolve(meta.getIdFieldName());
+ String nameField = resolve(meta.getNameFieldName());
String name = rowMeta.getString(row, nameField, "");
if (StringUtils.isEmpty(name)) {
throw new HopException(
