diff --git a/src/Functions/FunctionConstantBase.h b/src/Functions/FunctionConstantBase.h
index ad969268713..1bef8fbec8a 100644
--- a/src/Functions/FunctionConstantBase.h
+++ b/src/Functions/FunctionConstantBase.h
@@ -42,6 +42,12 @@ public:
 
     ColumnPtr executeImpl(const ColumnsWithTypeAndName &, const DataTypePtr & result_type, size_t input_rows_count) const override
     {
+        if (is_distributed)
+        {
+            auto result_column = result_type->createColumn();
+            result_column->insertMany(constant_value, input_rows_count);
+            return result_column;
+        }
         return result_type->createColumnConst(input_rows_count, constant_value);
     }