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. ==================