hi all,
The following message from Warden, we can discuss interaction between core
and dispatcher module here.
====================
I have drafted the communication messages between core and dispatcher as
below,
// submit sql
execute(RecordRequest) return RecordResponse;
RecordRequest {
String recordSql;
Enum engine; // Spark,Hive,Presto,etc.
String owner;
Integer maxRetryCount;
}
RecordResponse {
Integer code;
Long value;
Enum errorCode; // if code != 200, please tell us what happened:
// 1、 recordSql syntax error
// 2、 internal error, dispatcher self is crashed
// 3、 external error, target engine is crashed when dispatcher
call,etc
Exception ex; // error detail info
}
// validate sql syntax
validateSQL(CheckRequest) return CheckResponse;
ValidateSQLRequest {
String recordSql;
Enum engine; // Spark,Hive,Presto,etc.
}
ValidateSQLResponse {
Integer code;
Enum errorCode; // if code != 200, please tell us what happened:
// 1、 recordSql syntax error
// 2、 internal error, dispatcher self is crashed
// 3、 external error, target engine is crashed when dispatcher
call,etc
Exception ex; // error detail info
}
Could you please review it? Give us your feedback.
==================