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 +++++++++++++++++++++++++++++++++++++-----
 magento_sync_attribute_set.ktr | 59 +++++++++++++++++++++++++++++++++++++-----
 2 files changed, 106 insertions(+), 12 deletions(-)

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>
diff --git a/magento_sync_attribute_set.ktr b/magento_sync_attribute_set.ktr
index 1ecd2b2..aacef29 100644
--- a/magento_sync_attribute_set.ktr
+++ b/magento_sync_attribute_set.ktr
@@ -568,11 +568,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>Sort rows</to>
@@ -598,6 +593,16 @@
       <to>Unique rows</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>Select values</from>
+      <to>Sort rows 2</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Sort rows 2</from>
+      <to>Merge join</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <step>
     <name>Add constants</name>
@@ -697,7 +702,7 @@
       <schema_name/>
     </partitioning>
     <join_type>INNER</join_type>
-    <step1>Select values</step1>
+    <step1>Sort rows 2</step1>
     <step2>Table input 2</step2>
     <keys_1>
       <key>variant_id</key>
@@ -1167,6 +1172,48 @@ ORDER BY pp.id;</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>Sort rows 2</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>128</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>
-- 
cgit v1.2.3