diff --git a/apps/review/transfer_data.py b/apps/review/transfer_data.py
index f9c74908..af70873e 100644
--- a/apps/review/transfer_data.py
+++ b/apps/review/transfer_data.py
@@ -34,7 +34,7 @@ def transfer_languages():
 
 def transfer_reviews():
     establishments = Establishment.objects.filter(old_id__isnull=False).values_list('old_id', flat=True)
-    queryset = Reviews.objects.filter(
+    queryset = Reviews.objects.exclude(product_id__isnull=False).filter(
         establishment_id__in=list(establishments),
     ).values('id', 'reviewer_id', 'aasm_state', 'created_at', 'establishment_id', 'mark', 'vintage')
 
diff --git a/apps/transfer/serializers/reviews.py b/apps/transfer/serializers/reviews.py
index 25649b12..6e0db860 100644
--- a/apps/transfer/serializers/reviews.py
+++ b/apps/transfer/serializers/reviews.py
@@ -69,6 +69,7 @@ class ProductReviewSerializer(ReviewSerializer):
         data.pop('reviewer_id')
         data.pop('product_id')
         data.pop('aasm_state')
+        data.pop('establishment_id')
         return data
 
     def create(self, validated_data):