Skip to content

Commit 6c4f14e

Browse files
authored
Merge 9e73e3f into c0a403c
2 parents c0a403c + 9e73e3f commit 6c4f14e

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2158,17 +2158,13 @@ class TS3ReadCoroImpl : public TActorCoroImpl {
21582158
LOG_CORO_D("RunCoroBlockArrowParserOverFile - FINISHED");
21592159
}
21602160

2161-
STRICT_STFUNC_EXC(StateFunc,
2161+
STRICT_STFUNC(StateFunc,
21622162
hFunc(TEvPrivate::TEvReadStarted, Handle);
21632163
hFunc(TEvPrivate::TEvDataPart, Handle);
21642164
hFunc(TEvPrivate::TEvReadFinished, Handle);
21652165
hFunc(TEvPrivate::TEvContinue, Handle);
21662166
hFunc(TEvPrivate::TEvReadResult2, Handle);
21672167
hFunc(NActors::TEvents::TEvPoison, Handle);
2168-
, catch (const std::exception& e) {
2169-
TIssues issues{TIssue{TStringBuilder() << "An unknown exception has occurred: '" << e.what() << "'"}};
2170-
Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvAsyncInputError(InputIndex, issues, NYql::NDqProto::StatusIds::INTERNAL_ERROR));
2171-
}
21722168
)
21732169

21742170
void ProcessOneEvent() {

ydb/tests/tools/kqprun/.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,5 +2,6 @@ sync_dir
22
example
33
udfs
44
*.log
5+
*.json
56
*.sql
67
*.bin

ydb/tests/tools/kqprun/kqprun.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ void RunScript(const TExecutionOptions& executionOptions, const NKqpRun::TRunner
4848
if (!runner.ExecuteScript(executionOptions.ScriptQuery, executionOptions.ScriptQueryAction, executionOptions.ScriptTraceId)) {
4949
ythrow yexception() << "Script execution failed";
5050
}
51+
Cout << colors.Yellow() << "Fetching script results..." << colors.Default() << Endl;
5152
if (!runner.FetchScriptResults()) {
5253
ythrow yexception() << "Fetch script results failed";
5354
}
@@ -61,6 +62,8 @@ void RunScript(const TExecutionOptions& executionOptions, const NKqpRun::TRunner
6162
if (executionOptions.HasResults()) {
6263
runner.PrintScriptResults();
6364
}
65+
66+
Cout << colors.Yellow() << "Finalization of kqp runner..." << colors.Default() << Endl;
6467
}
6568

6669

0 commit comments

Comments
 (0)