yt/yql/tools/mrjob/mrjob.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

#include <yt/yql/providers/yt/job/yql_job_registry.h>

#include <yql/essentials/minikql/aligned_page_pool.h>
#include <yql/essentials/utils/backtrace/backtrace.h>

#include <yt/cpp/mapreduce/client/init.h>

#include <util/system/env.h>
#include <util/system/mlock.h>
#include <util/system/yassert.h>

int main(int argc, const char *argv[]) {
    Y_UNUSED(NKikimr::NUdf::GetStaticSymbols());
    try {
        LockAllMemory(LockCurrentMemory | LockFutureMemory);
    } catch (yexception&) {
        Cerr << "mlockall failed, but that's fine" << Endl;
    }

    if (GetEnv("YQL_USE_DEFAULT_ARROW_ALLOCATOR") == "1") {
        NKikimr::UseDefaultArrowAllocator();
    }

    NYql::NBacktrace::RegisterKikimrFatalActions();
    NYql::NBacktrace::EnableKikimrSymbolize();

    try {
        NYT::Initialize(argc, argv);
    } catch (...) {
        Cerr << CurrentExceptionMessage();
        return -1;
    }

    Y_ABORT("This binary should not be called directly");
}