Fixed issues

Author: GrigoriyPA

ydb/core/fq/libs/row_dispatcher/common.cpp

@@ -10,22 +10,26 @@ namespace {
 
 class TPureCalcProgramFactory : public IPureCalcProgramFactory {
 public:
-    NYql::NPureCalc::IProgramFactoryPtr GetFactory(const TSettings& settings) override {
-        TGuard<TMutex> guard(FactoriesMutex);
+    TPureCalcProgramFactory() {
+        CreateFactory({.EnabledLLVM = false});
+        CreateFactory({.EnabledLLVM = true});
+    }
 
+    NYql::NPureCalc::IProgramFactoryPtr GetFactory(const TSettings& settings) const override {
         const auto it = ProgramFactories.find(settings);
-        if (it != ProgramFactories.end()) {
-            return it->second;
-        }
+        Y_ENSURE(it != ProgramFactories.end());
+        return it->second;
+    }
 
-        return ProgramFactories.insert({settings, NYql::NPureCalc::MakeProgramFactory(
+private:
+    void CreateFactory(const TSettings& settings) {
+        ProgramFactories.insert({settings, NYql::NPureCalc::MakeProgramFactory(
             NYql::NPureCalc::TProgramFactoryOptions()
                 .SetLLVMSettings(settings.EnabledLLVM ? "ON" : "OFF")
-        )}).first->second;
+        )});
     }
 
 private:
-    TMutex FactoriesMutex;
     std::map<TSettings, NYql::NPureCalc::IProgramFactoryPtr> ProgramFactories;
 };
 

ydb/core/fq/libs/row_dispatcher/common.h

@@ -17,7 +17,7 @@ class IPureCalcProgramFactory : public TThrRefBase {
     };
 
 public:
-    virtual NYql::NPureCalc::IProgramFactoryPtr GetFactory(const TSettings& settings) = 0;
+    virtual NYql::NPureCalc::IProgramFactoryPtr GetFactory(const TSettings& settings) const = 0;
 };
 
 IPureCalcProgramFactory::TPtr CreatePureCalcProgramFactory();

ydb/library/yql/providers/pq/provider/yql_pq_dq_integration.cpp

@@ -209,7 +209,6 @@ class TPqDqIntegration: public TDqIntegrationBase {
                 srcDesc.SetClusterType(ToClusterType(clusterDesc->ClusterType));
                 srcDesc.SetDatabaseId(clusterDesc->DatabaseId);
 
-                srcDesc.SetEnabledLLVM(false);
                 if (const auto& types = State_->Types) {
                     if (const auto& optLLVM = types->OptLLVM) {
                         srcDesc.SetEnabledLLVM(!optLLVM->Empty() && *optLLVM != "OFF");