aboutsummaryrefslogtreecommitdiffstats
path: root/yql
diff options
context:
space:
mode:
authorcdzyura171 <cdzyura171@yandex-team.com>2025-02-10 11:53:19 +0300
committercdzyura171 <cdzyura171@yandex-team.com>2025-02-10 12:12:39 +0300
commit24f0f77bb308a9675f1aae84708724718f12282f (patch)
tree8a574286a14121e448609918089730004528ebeb /yql
parentb2fa5f3d3be16912e911d1c127db0c5a7b22c1a2 (diff)
downloadydb-24f0f77bb308a9675f1aae84708724718f12282f.tar.gz
Use coordinator and worker in fmrGateway
use coordinator and worker in fmrGateway commit_hash:a0977459dcbe041e5330c8959152be40fe18eea6
Diffstat (limited to 'yql')
-rw-r--r--yql/essentials/tools/yql_facade_run/yql_facade_run.cpp6
-rw-r--r--yql/essentials/utils/log/log_component.h4
2 files changed, 5 insertions, 5 deletions
diff --git a/yql/essentials/tools/yql_facade_run/yql_facade_run.cpp b/yql/essentials/tools/yql_facade_run/yql_facade_run.cpp
index 4cee954bd8..5a2dc645a6 100644
--- a/yql/essentials/tools/yql_facade_run/yql_facade_run.cpp
+++ b/yql/essentials/tools/yql_facade_run/yql_facade_run.cpp
@@ -281,13 +281,13 @@ void TFacadeRunOptions::Parse(int argc, const char *argv[]) {
opts.AddLongOption("scan-udfs", "Scan specified udfs with external udf-resolver to use static function registry").NoArgument().SetFlag(&ScanUdfs);
opts.AddLongOption("parse-only", "Parse program and exit").NoArgument().StoreValue(&Mode, ERunMode::Parse);
- opts.AddLongOption("compile-only", "Compiled program and exit").NoArgument().StoreValue(&Mode, ERunMode::Compile);
+ opts.AddLongOption("compile-only", "Compile program and exit").NoArgument().StoreValue(&Mode, ERunMode::Compile);
opts.AddLongOption("validate", "Validate program and exit").NoArgument().StoreValue(&Mode, ERunMode::Validate);
opts.AddLongOption("lineage", "Calculate program lineage and exit").NoArgument().StoreValue(&Mode, ERunMode::Lineage);
- opts.AddLongOption('O',"optimize", "Optimize program and exir").NoArgument().StoreValue(&Mode, ERunMode::Optimize);
+ opts.AddLongOption('O',"optimize", "Optimize program and exit").NoArgument().StoreValue(&Mode, ERunMode::Optimize);
opts.AddLongOption('D', "discover", "Discover tables in the program and exit").NoArgument().StoreValue(&Mode, ERunMode::Discover);
opts.AddLongOption("peephole", "Perform peephole program optimization and exit").NoArgument().StoreValue(&Mode, ERunMode::Peephole);
- opts.AddLongOption('R',"run", "Run progrum (use by default)").NoArgument().StoreValue(&Mode, ERunMode::Run);
+ opts.AddLongOption('R',"run", "Run program (use by default)").NoArgument().StoreValue(&Mode, ERunMode::Run);
opts.AddLongOption('L', "show-log", "Show transformation log").Optional().NoArgument().SetFlag(&ShowLog);
opts.AddLongOption('v', "verbosity", "Log verbosity level").Optional().RequiredArgument("LEVEL").StoreResult(&Verbosity);
diff --git a/yql/essentials/utils/log/log_component.h b/yql/essentials/utils/log/log_component.h
index 5cf9357ef4..be1df13863 100644
--- a/yql/essentials/utils/log/log_component.h
+++ b/yql/essentials/utils/log/log_component.h
@@ -83,7 +83,7 @@ struct EComponentHelpers {
case EComponent::ProviderGeneric: return TStringBuf("generic");
case EComponent::ProviderPg: return TStringBuf("PG");
case EComponent::ProviderPure: return TStringBuf("pure");
- case EComponent::FastMapReduce: return TStringBuf("fast map reduce");
+ case EComponent::FastMapReduce: return TStringBuf("FMR");
case EComponent::ProviderYtflow: return TStringBuf("YTFLOW");
default:
ythrow yexception() << "invalid log component value: "
@@ -119,7 +119,7 @@ struct EComponentHelpers {
if (str == TStringBuf("generic")) return EComponent::ProviderGeneric;
if (str == TStringBuf("PG")) return EComponent::ProviderPg;
if (str == TStringBuf("pure")) return EComponent::ProviderPure;
- if (str == TStringBuf("fast map reduce")) return EComponent::FastMapReduce;
+ if (str == TStringBuf("FMR")) return EComponent::FastMapReduce;
if (str == TStringBuf("YTFLOW")) return EComponent::ProviderYtflow;
ythrow yexception() << "unknown log component: '" << str << '\'';
}