Intermediate changes

2 files changed, 3 insertions, 1 deletions

diff --git a/yt/yql/plugin/native/error_helpers.cpp b/yt/yql/plugin/native/error_helpers.cpp
index 8301c341f9..e23d1fc497 100644
--- a/yt/yql/plugin/native/error_helpers.cpp
+++ b/yt/yql/plugin/native/error_helpers.cpp
@@ -45,7 +45,7 @@ TString IssuesToYtErrorYson(const NYql::TIssues& issues)
             writer.OnInt64Scalar(position.Column);
 
             writer.OnKeyedItem("row");
-            writer.OnInt64Scalar(position.Row);
+            writer.OnInt64Scalar(position.Row - 1); // First line is for required pragmas.
 
             if (!position.File.empty()) {
                 writer.OnKeyedItem("file");
diff --git a/yt/yql/plugin/native/plugin.cpp b/yt/yql/plugin/native/plugin.cpp
index b9a11ba1cb..ce8a4a1694 100644
--- a/yt/yql/plugin/native/plugin.cpp
+++ b/yt/yql/plugin/native/plugin.cpp
@@ -268,6 +268,8 @@ public:
             }
         });
 
+        program->SetResultType(NYql::IDataProvider::EResultFormat::Skiff);
+
         NSQLTranslation::TTranslationSettings sqlSettings;
         sqlSettings.ClusterMapping = Clusters_;
         sqlSettings.ModuleMapping = Modules_;