imay commented on a change in pull request #456: Add routine load statement
URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244903661
##########
File path:
fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
##########
@@ -55,155 +69,224 @@
* The routine load job support different streaming medium such as KAFKA
*/
public abstract class RoutineLoadJob implements Writable,
TxnStateChangeListener {
-
+
private static final Logger LOG =
LogManager.getLogger(RoutineLoadJob.class);
-
+
private static final int DEFAULT_TASK_TIMEOUT_SECONDS = 10;
private static final int BASE_OF_ERROR_RATE = 10000;
-
+ private static final String STAR_STRING = "*";
+
public enum JobState {
Review comment:
you'd better to add state transition diagram in the comments
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
