From 0d9c878e3d510efc0ff7f78b7f49ace3e06b9b75 Mon Sep 17 00:00:00 2001
From: FIN-IT_AndriFP <andrifebriyadiputra@gmail.com>
Date: Fri, 13 Feb 2026 15:58:56 +0700
Subject: (andri) fix sort from magento

---
 magento_has_sync.ktr | 59 ++++++++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 53 insertions(+), 6 deletions(-)

(limited to 'magento_has_sync.ktr')

diff --git a/magento_has_sync.ktr b/magento_has_sync.ktr
index cf62f7b..955389d 100644
--- a/magento_has_sync.ktr
+++ b/magento_has_sync.ktr
@@ -569,11 +569,6 @@
       <to>Merge join</to>
       <enabled>Y</enabled>
     </hop>
-    <hop>
-      <from>Select values</from>
-      <to>Merge join</to>
-      <enabled>Y</enabled>
-    </hop>
     <hop>
       <from>Merge join</from>
       <to>Select values 2</to>
@@ -594,6 +589,16 @@
       <to>Update 2</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>Select values</from>
+      <to>Sort rows</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Sort rows</from>
+      <to>Merge join</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <step>
     <name>Add constants</name>
@@ -658,7 +663,7 @@
       <schema_name/>
     </partitioning>
     <join_type>INNER</join_type>
-    <step1>Select values</step1>
+    <step1>Sort rows</step1>
     <step2>Table input 2</step2>
     <keys_1>
       <key>variant_id</key>
@@ -993,6 +998,48 @@ order by id</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>Sort rows</name>
+    <type>SortRows</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <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>
+    <fields>
+      <field>
+        <name>variant_id</name>
+        <ascending>Y</ascending>
+        <case_sensitive>N</case_sensitive>
+        <collator_enabled>N</collator_enabled>
+        <collator_strength>0</collator_strength>
+        <presorted>N</presorted>
+      </field>
+    </fields>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>560</xloc>
+      <yloc>112</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
-- 
cgit v1.2.3