This is an automated email from the ASF dual-hosted git repository.
hansva 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 22d0a0b4b4 Fix unit test 0006-groupby-concat (#5729)
22d0a0b4b4 is described below
commit 22d0a0b4b4f6fbbd16469b08f4e6153a16010b35
Author: Matteo <[email protected]>
AuthorDate: Wed Sep 24 12:44:39 2025 +0200
Fix unit test 0006-groupby-concat (#5729)
---
.../transforms/0006-groupby-concat.hpl | 58 +++++++++++++++-------
1 file changed, 41 insertions(+), 17 deletions(-)
diff --git a/integration-tests/transforms/0006-groupby-concat.hpl
b/integration-tests/transforms/0006-groupby-concat.hpl
index 3563d93757..ed68b04f85 100644
--- a/integration-tests/transforms/0006-groupby-concat.hpl
+++ b/integration-tests/transforms/0006-groupby-concat.hpl
@@ -54,15 +54,20 @@ limitations under the License.
<enabled>Y</enabled>
</hop>
<hop>
- <from>Memory group by</from>
- <to>Sort rows result</to>
+ <from>Group by</from>
+ <to>Merge Streams</to>
<enabled>Y</enabled>
</hop>
<hop>
- <from>Group by</from>
+ <from>Merge Streams</from>
<to>Sort rows result</to>
<enabled>Y</enabled>
</hop>
+ <hop>
+ <from>Memory group by</from>
+ <to>Merge Streams</to>
+ <enabled>Y</enabled>
+ </hop>
</order>
<transform>
<name>Data grid</name>
@@ -305,23 +310,20 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <directory>${java.io.tmpdir}</directory>
- <prefix>out</prefix>
- <sort_size>1000000</sort_size>
- <free_memory/>
<compress>N</compress>
- <compress_variable/>
- <unique_rows>N</unique_rows>
+ <directory>${java.io.tmpdir}</directory>
<fields>
<field>
- <name>KEY1</name>
<ascending>Y</ascending>
<case_sensitive>N</case_sensitive>
<collator_enabled>N</collator_enabled>
<collator_strength>0</collator_strength>
+ <name>KEY1</name>
<presorted>N</presorted>
</field>
</fields>
+ <sort_size>1000000</sort_size>
+ <unique_rows>N</unique_rows>
<attributes/>
<GUI>
<xloc>128</xloc>
@@ -339,23 +341,45 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <directory>${java.io.tmpdir}</directory>
- <prefix>out</prefix>
- <sort_size>1000000</sort_size>
- <free_memory/>
<compress>N</compress>
- <compress_variable/>
- <unique_rows>N</unique_rows>
+ <directory>${java.io.tmpdir}</directory>
<fields>
<field>
- <name>KEY1</name>
<ascending>Y</ascending>
<case_sensitive>N</case_sensitive>
<collator_enabled>N</collator_enabled>
<collator_strength>0</collator_strength>
+ <name>KEY1</name>
<presorted>N</presorted>
</field>
</fields>
+ <sort_size>1000000</sort_size>
+ <unique_rows>N</unique_rows>
+ <attributes/>
+ <GUI>
+ <xloc>512</xloc>
+ <yloc>144</yloc>
+ </GUI>
+ </transform>
+ <transform>
+ <name>Merge Streams</name>
+ <type>StreamSchema</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <transforms>
+ <transform>
+ <name>Group by</name>
+ </transform>
+ <transform>
+ <name>Memory group by</name>
+ </transform>
+ </transforms>
<attributes/>
<GUI>
<xloc>384</xloc>
