diff --git a/src/Dynamicweb.DataIntegration.Providers.EcomProvider.csproj b/src/Dynamicweb.DataIntegration.Providers.EcomProvider.csproj
index 65e599b..9afa077 100644
--- a/src/Dynamicweb.DataIntegration.Providers.EcomProvider.csproj
+++ b/src/Dynamicweb.DataIntegration.Providers.EcomProvider.csproj
@@ -1,6 +1,6 @@
 <Project Sdk="Microsoft.NET.Sdk">
 	<PropertyGroup>
-		<Version>10.8.1</Version>
+		<Version>10.8.2</Version>
 		<AssemblyVersion>1.0.0.0</AssemblyVersion>
 		<Title>Ecom Provider</Title>
 		<Description>Ecom Provider</Description>
diff --git a/src/EcomDestinationWriter.cs b/src/EcomDestinationWriter.cs
index 384aa08..16e0a6f 100644
--- a/src/EcomDestinationWriter.cs
+++ b/src/EcomDestinationWriter.cs
@@ -1107,6 +1107,7 @@ public void Write(Dictionary<string, object> row, Mapping mapping, bool discardD
                 break;
             case "EcomVariantGroups":
                 WriteVariantGroups(row, columnMappings, dataRow);
+                duplicateRowsHandler ??= new DuplicateRowsHandler(logger, job.Mappings);
                 break;
             case "EcomVariantsOptions":
                 WriteVariantOptions(row, columnMappings, dataRow);