dolphinscheduler_ddl.sql 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618
  1. /*
  2. * Licensed to the Apache Software Foundation (ASF) under one or more
  3. * contributor license agreements. See the NOTICE file distributed with
  4. * this work for additional information regarding copyright ownership.
  5. * The ASF licenses this file to You under the Apache License, Version 2.0
  6. * (the "License"); you may not use this file except in compliance with
  7. * the License. You may obtain a copy of the License at
  8. *
  9. * http://www.apache.org/licenses/LICENSE-2.0
  10. *
  11. * Unless required by applicable law or agreed to in writing, software
  12. * distributed under the License is distributed on an "AS IS" BASIS,
  13. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. * See the License for the specific language governing permissions and
  15. * limitations under the License.
  16. */
  17. /*
  18. Navicat MySQL Data Transfer
  19. Source Server : xx.xx
  20. Source Server Version : 50725
  21. Source Host : 192.168.xx.xx:3306
  22. Source Database : escheduler
  23. Target Server Type : MYSQL
  24. Target Server Version : 50725
  25. File Encoding : 65001
  26. Date: 2019-03-23 11:47:30
  27. */
  28. SET FOREIGN_KEY_CHECKS=0;
  29. -- ----------------------------
  30. -- Table structure for t_escheduler_alert
  31. -- ----------------------------
  32. DROP TABLE IF EXISTS `t_escheduler_alert`;
  33. CREATE TABLE `t_escheduler_alert` (
  34. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  35. `title` varchar(64) DEFAULT NULL COMMENT 'title',
  36. `show_type` tinyint(4) DEFAULT NULL COMMENT 'send email type,0:TABLE,1:TEXT',
  37. `content` text COMMENT 'Message content (can be email, can be SMS. Mail is stored in JSON map, and SMS is string)',
  38. `alert_type` tinyint(4) DEFAULT NULL COMMENT '0:email,1:sms',
  39. `alert_status` tinyint(4) DEFAULT '0' COMMENT '0:wait running,1:success,2:failed',
  40. `log` text COMMENT 'log',
  41. `alertgroup_id` int(11) DEFAULT NULL COMMENT 'alert group id',
  42. `receivers` text COMMENT 'receivers',
  43. `receivers_cc` text COMMENT 'cc',
  44. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  45. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  46. PRIMARY KEY (`id`)
  47. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  48. -- ----------------------------
  49. -- Table structure for t_escheduler_alertgroup
  50. -- ----------------------------
  51. DROP TABLE IF EXISTS `t_escheduler_alertgroup`;
  52. CREATE TABLE `t_escheduler_alertgroup` (
  53. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  54. `group_name` varchar(255) DEFAULT NULL COMMENT 'group name',
  55. `group_type` tinyint(4) DEFAULT NULL COMMENT 'Group type (message 0, SMS 1...)',
  56. `desc` varchar(255) DEFAULT NULL COMMENT 'description',
  57. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  58. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  59. PRIMARY KEY (`id`)
  60. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  61. -- ----------------------------
  62. -- Table structure for t_escheduler_command
  63. -- ----------------------------
  64. DROP TABLE IF EXISTS `t_escheduler_command`;
  65. CREATE TABLE `t_escheduler_command` (
  66. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  67. `command_type` tinyint(4) DEFAULT NULL COMMENT 'Command type: 0 start workflow, 1 start execution from current node, 2 resume fault-tolerant workflow, 3 resume pause process, 4 start execution from failed node, 5 complement, 6 schedule, 7 rerun, 8 pause, 9 stop, 10 resume waiting thread',
  68. `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id',
  69. `command_param` text COMMENT 'json command parameters',
  70. `task_depend_type` tinyint(4) DEFAULT NULL COMMENT 'Node dependency type: 0 current node, 1 forward, 2 backward',
  71. `failure_strategy` tinyint(4) DEFAULT '0' COMMENT 'Failed policy: 0 end, 1 continue',
  72. `warning_type` tinyint(4) DEFAULT '0' COMMENT 'Alarm type: 0 is not sent, 1 process is sent successfully, 2 process is sent failed, 3 process is sent successfully and all failures are sent',
  73. `warning_group_id` int(11) DEFAULT NULL COMMENT 'warning group',
  74. `schedule_time` datetime DEFAULT NULL COMMENT 'schedule time',
  75. `start_time` datetime DEFAULT NULL COMMENT 'start time',
  76. `executor_id` int(11) DEFAULT NULL COMMENT 'executor id',
  77. `dependence` varchar(255) DEFAULT NULL COMMENT 'dependence',
  78. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  79. `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority: 0 Highest,1 High,2 Medium,3 Low,4 Lowest',
  80. PRIMARY KEY (`id`)
  81. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  82. -- ----------------------------
  83. -- Table structure for t_escheduler_datasource
  84. -- ----------------------------
  85. DROP TABLE IF EXISTS `t_escheduler_datasource`;
  86. CREATE TABLE `t_escheduler_datasource` (
  87. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  88. `name` varchar(64) NOT NULL COMMENT 'data source name',
  89. `note` varchar(256) DEFAULT NULL COMMENT 'description',
  90. `type` tinyint(4) NOT NULL COMMENT 'data source type: 0:mysql,1:postgresql,2:hive,3:spark',
  91. `user_id` int(11) NOT NULL COMMENT 'the creator id',
  92. `connection_params` text NOT NULL COMMENT 'json connection params',
  93. `create_time` datetime NOT NULL COMMENT 'create time',
  94. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  95. PRIMARY KEY (`id`)
  96. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  97. -- ----------------------------
  98. -- Table structure for t_escheduler_master_server
  99. -- ----------------------------
  100. DROP TABLE IF EXISTS `t_escheduler_master_server`;
  101. CREATE TABLE `t_escheduler_master_server` (
  102. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  103. `host` varchar(45) DEFAULT NULL COMMENT 'ip',
  104. `port` int(11) DEFAULT NULL COMMENT 'port',
  105. `zk_directory` varchar(64) DEFAULT NULL COMMENT 'the server path in zk directory',
  106. `res_info` varchar(256) DEFAULT NULL COMMENT 'json resource information:{"cpu":xxx,"memroy":xxx}',
  107. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  108. `last_heartbeat_time` datetime DEFAULT NULL COMMENT 'last head beat time',
  109. PRIMARY KEY (`id`)
  110. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  111. -- ----------------------------
  112. -- Table structure for t_escheduler_process_definition
  113. -- ----------------------------
  114. DROP TABLE IF EXISTS `t_escheduler_process_definition`;
  115. CREATE TABLE `t_escheduler_process_definition` (
  116. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  117. `name` varchar(255) DEFAULT NULL COMMENT 'process definition name',
  118. `version` int(11) DEFAULT NULL COMMENT 'process definition version',
  119. `release_state` tinyint(4) DEFAULT NULL COMMENT 'process definition release state:0:offline,1:online',
  120. `project_id` int(11) DEFAULT NULL COMMENT 'project id',
  121. `user_id` int(11) DEFAULT NULL COMMENT 'process definition creator id',
  122. `process_definition_json` longtext COMMENT 'process definition json content',
  123. `desc` text COMMENT 'process definition description',
  124. `global_params` text COMMENT 'global parameters',
  125. `flag` tinyint(4) DEFAULT NULL COMMENT '0 not available, 1 available',
  126. `locations` text COMMENT 'Node location information',
  127. `connects` text COMMENT 'Node connection information',
  128. `receivers` text COMMENT 'receivers',
  129. `receivers_cc` text COMMENT 'cc',
  130. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  131. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  132. PRIMARY KEY (`id`),
  133. KEY `process_definition_index` (`project_id`,`id`) USING BTREE
  134. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  135. -- ----------------------------
  136. -- Table structure for t_escheduler_process_instance
  137. -- ----------------------------
  138. DROP TABLE IF EXISTS `t_escheduler_process_instance`;
  139. CREATE TABLE `t_escheduler_process_instance` (
  140. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  141. `name` varchar(255) DEFAULT NULL COMMENT 'process instance name',
  142. `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id',
  143. `state` tinyint(4) DEFAULT NULL COMMENT 'process instance Status: 0 commit succeeded, 1 running, 2 prepare to pause, 3 pause, 4 prepare to stop, 5 stop, 6 fail, 7 succeed, 8 need fault tolerance, 9 kill, 10 wait for thread, 11 wait for dependency to complete',
  144. `recovery` tinyint(4) DEFAULT NULL COMMENT 'process instance failover flag:0:normal,1:failover instance',
  145. `start_time` datetime DEFAULT NULL COMMENT 'process instance start time',
  146. `end_time` datetime DEFAULT NULL COMMENT 'process instance end time',
  147. `run_times` int(11) DEFAULT NULL COMMENT 'process instance run times',
  148. `host` varchar(45) DEFAULT NULL COMMENT 'process instance host',
  149. `command_type` tinyint(4) DEFAULT NULL COMMENT 'command type',
  150. `command_param` text COMMENT 'json command parameters',
  151. `task_depend_type` tinyint(4) DEFAULT NULL COMMENT 'task depend type. 0: only current node,1:before the node,2:later nodes',
  152. `max_try_times` tinyint(4) DEFAULT '0' COMMENT 'max try times',
  153. `failure_strategy` tinyint(4) DEFAULT '0' COMMENT 'failure strategy. 0:end the process when node failed,1:continue running the other nodes when node failed',
  154. `warning_type` tinyint(4) DEFAULT '0' COMMENT 'warning type. 0:no warning,1:warning if process success,2:warning if process failed,3:warning if success',
  155. `warning_group_id` int(11) DEFAULT NULL COMMENT 'warning group id',
  156. `schedule_time` datetime DEFAULT NULL COMMENT 'schedule time',
  157. `command_start_time` datetime DEFAULT NULL COMMENT 'command start time',
  158. `global_params` text COMMENT 'global parameters',
  159. `process_instance_json` longtext COMMENT 'process instance json(copy的process definition 的json)',
  160. `flag` tinyint(4) DEFAULT '1' COMMENT 'flag',
  161. `update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  162. `is_sub_process` int(11) DEFAULT '0' COMMENT 'flag, whether the process is sub process',
  163. `executor_id` int(11) NOT NULL COMMENT 'executor id',
  164. `locations` text COMMENT 'Node location information',
  165. `connects` text COMMENT 'Node connection information',
  166. `history_cmd` text COMMENT 'history commands of process instance operation',
  167. `dependence_schedule_times` text COMMENT 'depend schedule fire time',
  168. `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority. 0 Highest,1 High,2 Medium,3 Low,4 Lowest',
  169. PRIMARY KEY (`id`),
  170. KEY `process_instance_index` (`process_definition_id`,`id`) USING BTREE,
  171. KEY `start_time_index` (`start_time`) USING BTREE
  172. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  173. -- ----------------------------
  174. -- Table structure for t_escheduler_project
  175. -- ----------------------------
  176. DROP TABLE IF EXISTS `t_escheduler_project`;
  177. CREATE TABLE `t_escheduler_project` (
  178. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  179. `name` varchar(100) DEFAULT NULL COMMENT 'project name',
  180. `desc` varchar(200) DEFAULT NULL COMMENT 'project description',
  181. `user_id` int(11) DEFAULT NULL COMMENT 'creator id',
  182. `flag` tinyint(4) DEFAULT '1' COMMENT '0 not available, 1 available',
  183. `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  184. `update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT 'update time',
  185. PRIMARY KEY (`id`),
  186. KEY `user_id_index` (`user_id`) USING BTREE
  187. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  188. -- ----------------------------
  189. -- Table structure for t_escheduler_queue
  190. -- ----------------------------
  191. DROP TABLE IF EXISTS `t_escheduler_queue`;
  192. CREATE TABLE `t_escheduler_queue` (
  193. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  194. `queue_name` varchar(64) DEFAULT NULL COMMENT 'queue name',
  195. `queue` varchar(64) DEFAULT NULL COMMENT 'yarn queue name',
  196. PRIMARY KEY (`id`)
  197. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  198. -- ----------------------------
  199. -- Table structure for t_escheduler_relation_datasource_user
  200. -- ----------------------------
  201. DROP TABLE IF EXISTS `t_escheduler_relation_datasource_user`;
  202. CREATE TABLE `t_escheduler_relation_datasource_user` (
  203. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  204. `user_id` int(11) NOT NULL COMMENT 'user id',
  205. `datasource_id` int(11) DEFAULT NULL COMMENT 'data source id',
  206. `perm` int(11) DEFAULT '1' COMMENT 'limits of authority',
  207. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  208. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  209. PRIMARY KEY (`id`)
  210. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  211. -- ----------------------------
  212. -- Table structure for t_escheduler_relation_process_instance
  213. -- ----------------------------
  214. DROP TABLE IF EXISTS `t_escheduler_relation_process_instance`;
  215. CREATE TABLE `t_escheduler_relation_process_instance` (
  216. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  217. `parent_process_instance_id` int(11) DEFAULT NULL COMMENT 'parent process instance id',
  218. `parent_task_instance_id` int(11) DEFAULT NULL COMMENT 'parent process instance id',
  219. `process_instance_id` int(11) DEFAULT NULL COMMENT 'child process instance id',
  220. PRIMARY KEY (`id`)
  221. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  222. -- ----------------------------
  223. -- Table structure for t_escheduler_relation_project_user
  224. -- ----------------------------
  225. DROP TABLE IF EXISTS `t_escheduler_relation_project_user`;
  226. CREATE TABLE `t_escheduler_relation_project_user` (
  227. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  228. `user_id` int(11) NOT NULL COMMENT 'user id',
  229. `project_id` int(11) DEFAULT NULL COMMENT 'project id',
  230. `perm` int(11) DEFAULT '1' COMMENT 'limits of authority',
  231. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  232. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  233. PRIMARY KEY (`id`),
  234. KEY `user_id_index` (`user_id`) USING BTREE
  235. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  236. -- ----------------------------
  237. -- Table structure for t_escheduler_relation_resources_user
  238. -- ----------------------------
  239. DROP TABLE IF EXISTS `t_escheduler_relation_resources_user`;
  240. CREATE TABLE `t_escheduler_relation_resources_user` (
  241. `id` int(11) NOT NULL AUTO_INCREMENT,
  242. `user_id` int(11) NOT NULL COMMENT 'user id',
  243. `resources_id` int(11) DEFAULT NULL COMMENT 'resource id',
  244. `perm` int(11) DEFAULT '1' COMMENT 'limits of authority',
  245. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  246. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  247. PRIMARY KEY (`id`)
  248. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  249. -- ----------------------------
  250. -- Table structure for t_escheduler_relation_udfs_user
  251. -- ----------------------------
  252. DROP TABLE IF EXISTS `t_escheduler_relation_udfs_user`;
  253. CREATE TABLE `t_escheduler_relation_udfs_user` (
  254. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  255. `user_id` int(11) NOT NULL COMMENT 'userid',
  256. `udf_id` int(11) DEFAULT NULL COMMENT 'udf id',
  257. `perm` int(11) DEFAULT '1' COMMENT 'limits of authority',
  258. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  259. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  260. PRIMARY KEY (`id`)
  261. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  262. -- ----------------------------
  263. -- Table structure for t_escheduler_relation_user_alertgroup
  264. -- ----------------------------
  265. DROP TABLE IF EXISTS `t_escheduler_relation_user_alertgroup`;
  266. CREATE TABLE `t_escheduler_relation_user_alertgroup` (
  267. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  268. `alertgroup_id` int(11) DEFAULT NULL COMMENT 'alert group id',
  269. `user_id` int(11) DEFAULT NULL COMMENT 'user id',
  270. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  271. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  272. PRIMARY KEY (`id`)
  273. ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
  274. -- ----------------------------
  275. -- Table structure for t_escheduler_resources
  276. -- ----------------------------
  277. DROP TABLE IF EXISTS `t_escheduler_resources`;
  278. CREATE TABLE `t_escheduler_resources` (
  279. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  280. `alias` varchar(64) DEFAULT NULL COMMENT 'alias',
  281. `file_name` varchar(64) DEFAULT NULL COMMENT 'file name',
  282. `desc` varchar(256) DEFAULT NULL COMMENT 'description',
  283. `user_id` int(11) DEFAULT NULL COMMENT 'user id',
  284. `type` tinyint(4) DEFAULT NULL COMMENT 'resource type,0:FILE,1:UDF',
  285. `size` bigint(20) DEFAULT NULL COMMENT 'resource size',
  286. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  287. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  288. PRIMARY KEY (`id`)
  289. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  290. -- ----------------------------
  291. -- Table structure for t_escheduler_schedules
  292. -- ----------------------------
  293. DROP TABLE IF EXISTS `t_escheduler_schedules`;
  294. CREATE TABLE `t_escheduler_schedules` (
  295. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  296. `process_definition_id` int(11) NOT NULL COMMENT 'process definition id',
  297. `start_time` datetime NOT NULL COMMENT 'start time',
  298. `end_time` datetime NOT NULL COMMENT 'end time',
  299. `crontab` varchar(256) NOT NULL COMMENT 'crontab description',
  300. `failure_strategy` tinyint(4) NOT NULL COMMENT 'failure strategy. 0:end,1:continue',
  301. `user_id` int(11) NOT NULL COMMENT 'user id',
  302. `release_state` tinyint(4) NOT NULL COMMENT 'release state. 0:offline,1:online ',
  303. `warning_type` tinyint(4) NOT NULL COMMENT 'Alarm type: 0 is not sent, 1 process is sent successfully, 2 process is sent failed, 3 process is sent successfully and all failures are sent',
  304. `warning_group_id` int(11) DEFAULT NULL COMMENT 'alert group id',
  305. `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority:0 Highest,1 High,2 Medium,3 Low,4 Lowest',
  306. `create_time` datetime NOT NULL COMMENT 'create time',
  307. `update_time` datetime NOT NULL COMMENT 'update time',
  308. PRIMARY KEY (`id`)
  309. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  310. -- ----------------------------
  311. -- Table structure for t_escheduler_session
  312. -- ----------------------------
  313. DROP TABLE IF EXISTS `t_escheduler_session`;
  314. CREATE TABLE `t_escheduler_session` (
  315. `id` varchar(64) NOT NULL COMMENT 'key',
  316. `user_id` int(11) DEFAULT NULL COMMENT 'user id',
  317. `ip` varchar(45) DEFAULT NULL COMMENT 'ip',
  318. `last_login_time` datetime DEFAULT NULL COMMENT 'last login time',
  319. PRIMARY KEY (`id`)
  320. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  321. -- ----------------------------
  322. -- Table structure for t_escheduler_task_instance
  323. -- ----------------------------
  324. DROP TABLE IF EXISTS `t_escheduler_task_instance`;
  325. CREATE TABLE `t_escheduler_task_instance` (
  326. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  327. `name` varchar(255) DEFAULT NULL COMMENT 'task name',
  328. `task_type` varchar(64) DEFAULT NULL COMMENT 'task type',
  329. `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id',
  330. `process_instance_id` int(11) DEFAULT NULL COMMENT 'process instance id',
  331. `task_json` longtext COMMENT 'task content json',
  332. `state` tinyint(4) DEFAULT NULL COMMENT 'Status: 0 commit succeeded, 1 running, 2 prepare to pause, 3 pause, 4 prepare to stop, 5 stop, 6 fail, 7 succeed, 8 need fault tolerance, 9 kill, 10 wait for thread, 11 wait for dependency to complete',
  333. `submit_time` datetime DEFAULT NULL COMMENT 'task submit time',
  334. `start_time` datetime DEFAULT NULL COMMENT 'task start time',
  335. `end_time` datetime DEFAULT NULL COMMENT 'task end time',
  336. `host` varchar(45) DEFAULT NULL COMMENT 'host of task running on',
  337. `execute_path` varchar(200) DEFAULT NULL COMMENT 'task execute path in the host',
  338. `log_path` varchar(200) DEFAULT NULL COMMENT 'task log path',
  339. `alert_flag` tinyint(4) DEFAULT NULL COMMENT 'whether alert',
  340. `retry_times` int(4) DEFAULT '0' COMMENT 'task retry times',
  341. `pid` int(4) DEFAULT NULL COMMENT 'pid of task',
  342. `app_link` varchar(255) DEFAULT NULL COMMENT 'yarn app id',
  343. `flag` tinyint(4) DEFAULT '1' COMMENT '0 not available, 1 available',
  344. `retry_interval` int(4) DEFAULT NULL COMMENT 'retry interval when task failed ',
  345. `max_retry_times` int(2) DEFAULT NULL COMMENT 'max retry times',
  346. `task_instance_priority` int(11) DEFAULT NULL COMMENT 'task instance priority:0 Highest,1 High,2 Medium,3 Low,4 Lowest',
  347. PRIMARY KEY (`id`),
  348. KEY `process_instance_id` (`process_instance_id`) USING BTREE,
  349. KEY `task_instance_index` (`process_definition_id`,`process_instance_id`) USING BTREE,
  350. CONSTRAINT `foreign_key_instance_id` FOREIGN KEY (`process_instance_id`) REFERENCES `t_escheduler_process_instance` (`id`) ON DELETE CASCADE
  351. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  352. -- ----------------------------
  353. -- Table structure for t_escheduler_tenant
  354. -- ----------------------------
  355. DROP TABLE IF EXISTS `t_escheduler_tenant`;
  356. CREATE TABLE `t_escheduler_tenant` (
  357. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  358. `tenant_code` varchar(64) DEFAULT NULL COMMENT 'tenant code',
  359. `tenant_name` varchar(64) DEFAULT NULL COMMENT 'tenant name',
  360. `desc` varchar(256) DEFAULT NULL COMMENT 'description',
  361. `queue_id` int(11) DEFAULT NULL COMMENT 'queue id',
  362. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  363. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  364. PRIMARY KEY (`id`)
  365. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  366. -- ----------------------------
  367. -- Table structure for t_escheduler_udfs
  368. -- ----------------------------
  369. DROP TABLE IF EXISTS `t_escheduler_udfs`;
  370. CREATE TABLE `t_escheduler_udfs` (
  371. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  372. `user_id` int(11) NOT NULL COMMENT 'user id',
  373. `func_name` varchar(100) NOT NULL COMMENT 'UDF function name',
  374. `class_name` varchar(255) NOT NULL COMMENT 'class of udf',
  375. `type` tinyint(4) NOT NULL COMMENT 'Udf function type',
  376. `arg_types` varchar(255) DEFAULT NULL COMMENT 'arguments types',
  377. `database` varchar(255) DEFAULT NULL COMMENT 'data base',
  378. `desc` varchar(255) DEFAULT NULL COMMENT 'description',
  379. `resource_id` int(11) NOT NULL COMMENT 'resource id',
  380. `resource_name` varchar(255) NOT NULL COMMENT 'resource name',
  381. `create_time` datetime NOT NULL COMMENT 'create time',
  382. `update_time` datetime NOT NULL COMMENT 'update time',
  383. PRIMARY KEY (`id`)
  384. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  385. -- ----------------------------
  386. -- Table structure for t_escheduler_user
  387. -- ----------------------------
  388. DROP TABLE IF EXISTS `t_escheduler_user`;
  389. CREATE TABLE `t_escheduler_user` (
  390. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'user id',
  391. `user_name` varchar(64) DEFAULT NULL COMMENT 'user name',
  392. `user_password` varchar(64) DEFAULT NULL COMMENT 'user password',
  393. `user_type` tinyint(4) DEFAULT NULL COMMENT 'user type, 0:administrator,1:ordinary user',
  394. `email` varchar(64) DEFAULT NULL COMMENT 'email',
  395. `phone` varchar(11) DEFAULT NULL COMMENT 'phone',
  396. `tenant_id` int(11) DEFAULT NULL COMMENT 'tenant id',
  397. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  398. `update_time` datetime DEFAULT NULL COMMENT 'update time',
  399. PRIMARY KEY (`id`),
  400. UNIQUE KEY `user_name_unique` (`user_name`)
  401. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  402. -- ----------------------------
  403. -- Table structure for t_escheduler_worker_server
  404. -- ----------------------------
  405. DROP TABLE IF EXISTS `t_escheduler_worker_server`;
  406. CREATE TABLE `t_escheduler_worker_server` (
  407. `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key',
  408. `host` varchar(45) DEFAULT NULL COMMENT 'ip',
  409. `port` int(11) DEFAULT NULL COMMENT 'process id',
  410. `zk_directory` varchar(64) CHARACTER SET utf8 COLLATE utf8_bin DEFAULT NULL COMMENT 'zk path',
  411. `res_info` varchar(255) DEFAULT NULL COMMENT 'json resource info,{"cpu":xxx,"memroy":xxx}',
  412. `create_time` datetime DEFAULT NULL COMMENT 'create time',
  413. `last_heartbeat_time` datetime DEFAULT NULL COMMENT 'update time',
  414. PRIMARY KEY (`id`)
  415. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  416. /*drop table first */
  417. DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
  418. DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
  419. DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
  420. DROP TABLE IF EXISTS QRTZ_LOCKS;
  421. DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;
  422. DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS;
  423. DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;
  424. DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;
  425. DROP TABLE IF EXISTS QRTZ_TRIGGERS;
  426. DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;
  427. DROP TABLE IF EXISTS QRTZ_CALENDARS;
  428. CREATE TABLE QRTZ_JOB_DETAILS(
  429. SCHED_NAME VARCHAR(120) NOT NULL,
  430. JOB_NAME VARCHAR(200) NOT NULL,
  431. JOB_GROUP VARCHAR(200) NOT NULL,
  432. DESCRIPTION VARCHAR(250) NULL,
  433. JOB_CLASS_NAME VARCHAR(250) NOT NULL,
  434. IS_DURABLE VARCHAR(1) NOT NULL,
  435. IS_NONCONCURRENT VARCHAR(1) NOT NULL,
  436. IS_UPDATE_DATA VARCHAR(1) NOT NULL,
  437. REQUESTS_RECOVERY VARCHAR(1) NOT NULL,
  438. JOB_DATA BLOB NULL,
  439. PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP))
  440. ENGINE=InnoDB;
  441. CREATE TABLE QRTZ_TRIGGERS (
  442. SCHED_NAME VARCHAR(120) NOT NULL,
  443. TRIGGER_NAME VARCHAR(200) NOT NULL,
  444. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  445. JOB_NAME VARCHAR(200) NOT NULL,
  446. JOB_GROUP VARCHAR(200) NOT NULL,
  447. DESCRIPTION VARCHAR(250) NULL,
  448. NEXT_FIRE_TIME BIGINT(13) NULL,
  449. PREV_FIRE_TIME BIGINT(13) NULL,
  450. PRIORITY INTEGER NULL,
  451. TRIGGER_STATE VARCHAR(16) NOT NULL,
  452. TRIGGER_TYPE VARCHAR(8) NOT NULL,
  453. START_TIME BIGINT(13) NOT NULL,
  454. END_TIME BIGINT(13) NULL,
  455. CALENDAR_NAME VARCHAR(200) NULL,
  456. MISFIRE_INSTR SMALLINT(2) NULL,
  457. JOB_DATA BLOB NULL,
  458. PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
  459. FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
  460. REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP))
  461. ENGINE=InnoDB;
  462. CREATE TABLE QRTZ_SIMPLE_TRIGGERS (
  463. SCHED_NAME VARCHAR(120) NOT NULL,
  464. TRIGGER_NAME VARCHAR(200) NOT NULL,
  465. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  466. REPEAT_COUNT BIGINT(7) NOT NULL,
  467. REPEAT_INTERVAL BIGINT(12) NOT NULL,
  468. TIMES_TRIGGERED BIGINT(10) NOT NULL,
  469. PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
  470. FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
  471. REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
  472. ENGINE=InnoDB;
  473. CREATE TABLE QRTZ_CRON_TRIGGERS (
  474. SCHED_NAME VARCHAR(120) NOT NULL,
  475. TRIGGER_NAME VARCHAR(200) NOT NULL,
  476. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  477. CRON_EXPRESSION VARCHAR(120) NOT NULL,
  478. TIME_ZONE_ID VARCHAR(80),
  479. PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
  480. FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
  481. REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
  482. ENGINE=InnoDB;
  483. CREATE TABLE QRTZ_SIMPROP_TRIGGERS
  484. (
  485. SCHED_NAME VARCHAR(120) NOT NULL,
  486. TRIGGER_NAME VARCHAR(200) NOT NULL,
  487. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  488. STR_PROP_1 VARCHAR(512) NULL,
  489. STR_PROP_2 VARCHAR(512) NULL,
  490. STR_PROP_3 VARCHAR(512) NULL,
  491. INT_PROP_1 INT NULL,
  492. INT_PROP_2 INT NULL,
  493. LONG_PROP_1 BIGINT NULL,
  494. LONG_PROP_2 BIGINT NULL,
  495. DEC_PROP_1 NUMERIC(13,4) NULL,
  496. DEC_PROP_2 NUMERIC(13,4) NULL,
  497. BOOL_PROP_1 VARCHAR(1) NULL,
  498. BOOL_PROP_2 VARCHAR(1) NULL,
  499. PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
  500. FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
  501. REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
  502. ENGINE=InnoDB;
  503. CREATE TABLE QRTZ_BLOB_TRIGGERS (
  504. SCHED_NAME VARCHAR(120) NOT NULL,
  505. TRIGGER_NAME VARCHAR(200) NOT NULL,
  506. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  507. BLOB_DATA BLOB NULL,
  508. PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
  509. INDEX (SCHED_NAME,TRIGGER_NAME, TRIGGER_GROUP),
  510. FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
  511. REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))
  512. ENGINE=InnoDB;
  513. CREATE TABLE QRTZ_CALENDARS (
  514. SCHED_NAME VARCHAR(120) NOT NULL,
  515. CALENDAR_NAME VARCHAR(200) NOT NULL,
  516. CALENDAR BLOB NOT NULL,
  517. PRIMARY KEY (SCHED_NAME,CALENDAR_NAME))
  518. ENGINE=InnoDB;
  519. CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS (
  520. SCHED_NAME VARCHAR(120) NOT NULL,
  521. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  522. PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP))
  523. ENGINE=InnoDB;
  524. CREATE TABLE QRTZ_FIRED_TRIGGERS (
  525. SCHED_NAME VARCHAR(120) NOT NULL,
  526. ENTRY_ID VARCHAR(95) NOT NULL,
  527. TRIGGER_NAME VARCHAR(200) NOT NULL,
  528. TRIGGER_GROUP VARCHAR(200) NOT NULL,
  529. INSTANCE_NAME VARCHAR(200) NOT NULL,
  530. FIRED_TIME BIGINT(13) NOT NULL,
  531. SCHED_TIME BIGINT(13) NOT NULL,
  532. PRIORITY INTEGER NOT NULL,
  533. STATE VARCHAR(16) NOT NULL,
  534. JOB_NAME VARCHAR(200) NULL,
  535. JOB_GROUP VARCHAR(200) NULL,
  536. IS_NONCONCURRENT VARCHAR(1) NULL,
  537. REQUESTS_RECOVERY VARCHAR(1) NULL,
  538. PRIMARY KEY (SCHED_NAME,ENTRY_ID))
  539. ENGINE=InnoDB;
  540. CREATE TABLE QRTZ_SCHEDULER_STATE (
  541. SCHED_NAME VARCHAR(120) NOT NULL,
  542. INSTANCE_NAME VARCHAR(200) NOT NULL,
  543. LAST_CHECKIN_TIME BIGINT(13) NOT NULL,
  544. CHECKIN_INTERVAL BIGINT(13) NOT NULL,
  545. PRIMARY KEY (SCHED_NAME,INSTANCE_NAME))
  546. ENGINE=InnoDB;
  547. CREATE TABLE QRTZ_LOCKS (
  548. SCHED_NAME VARCHAR(120) NOT NULL,
  549. LOCK_NAME VARCHAR(40) NOT NULL,
  550. PRIMARY KEY (SCHED_NAME,LOCK_NAME))
  551. ENGINE=InnoDB;
  552. CREATE INDEX IDX_QRTZ_J_REQ_RECOVERY ON QRTZ_JOB_DETAILS(SCHED_NAME,REQUESTS_RECOVERY);
  553. CREATE INDEX IDX_QRTZ_J_GRP ON QRTZ_JOB_DETAILS(SCHED_NAME,JOB_GROUP);
  554. CREATE INDEX IDX_QRTZ_T_J ON QRTZ_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);
  555. CREATE INDEX IDX_QRTZ_T_JG ON QRTZ_TRIGGERS(SCHED_NAME,JOB_GROUP);
  556. CREATE INDEX IDX_QRTZ_T_C ON QRTZ_TRIGGERS(SCHED_NAME,CALENDAR_NAME);
  557. CREATE INDEX IDX_QRTZ_T_G ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);
  558. CREATE INDEX IDX_QRTZ_T_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE);
  559. CREATE INDEX IDX_QRTZ_T_N_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_STATE);
  560. CREATE INDEX IDX_QRTZ_T_N_G_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP,TRIGGER_STATE);
  561. CREATE INDEX IDX_QRTZ_T_NEXT_FIRE_TIME ON QRTZ_TRIGGERS(SCHED_NAME,NEXT_FIRE_TIME);
  562. CREATE INDEX IDX_QRTZ_T_NFT_ST ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE,NEXT_FIRE_TIME);
  563. CREATE INDEX IDX_QRTZ_T_NFT_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME);
  564. CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_STATE);
  565. CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE_GRP ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_GROUP,TRIGGER_STATE);
  566. CREATE INDEX IDX_QRTZ_FT_TRIG_INST_NAME ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME);
  567. CREATE INDEX IDX_QRTZ_FT_INST_JOB_REQ_RCVRY ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME,REQUESTS_RECOVERY);
  568. CREATE INDEX IDX_QRTZ_FT_J_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);
  569. CREATE INDEX IDX_QRTZ_FT_JG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_GROUP);
  570. CREATE INDEX IDX_QRTZ_FT_T_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP);
  571. CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);
  572. commit;