yystopf
/
piflow
forked from opensci/piflow
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
494 Commits 16 Branches 0 Tags 88 MiB
Commit Graph

72 Commits

Author SHA1 Message Date
judy0131 b4d790ce83 modify debug run mode api 2019-08-19 18:54:03 +08:00
judy0131 6873944e02 modify flow debug api 2019-08-15 14:26:41 +08:00
judy_0131 50acf9c6fd fix bug: ConfigurableIncrementalStop throw file not found exception 2019-07-31 14:29:14 +08:00
judy_0131 0839e1c1a1 fix putHiveQL bug 2019-07-29 13:52:19 +08:00
coco11563 e9ddb1d1b0 bug fix 2019-07-26 11:20:45 +08:00
judy0131 10756edc57 test 2019-07-26 08:46:17 +08:00
judy0131 b589211c1a fix bug 2019-07-23 18:10:47 +08:00
judy0131 b85fd2cc54 1.optimize code 
2.fix bug
 2019-07-22 11:14:36 +08:00
judy0131 db63cfa57d Merge remote-tracking branch 'origin/master' 2019-07-19 18:35:17 +08:00
judy0131 acf29d16bd increment for jdbc type 2019-07-19 18:34:59 +08:00
coco11563 02ad523f53 adding nsfc module 2019-07-17 18:01:26 +08:00
judy0131 8eea5e0041 fix bug: start flow slowly 2019-06-21 15:12:32 +08:00
judy0131 a8aab1951d fix bug 2019-05-16 16:29:35 +08:00
judy0131 ac4e3043d6 add getProjectInfo API 2019-05-16 16:06:26 +08:00
judy0131 7ee00efec5 add getFlowGroupInfo API 2019-05-16 15:46:11 +08:00
judy0131 c64f492db6 update state when stop flowGroup or project 2019-05-16 10:03:42 +08:00
judy0131 c8c01811b4 monitor project 2019-05-15 12:27:13 +08:00
judy0131 0fff9ec29b monitor flow group 
1.change the schema of table Flow
2.add table flowGroup and project
3.store flow group data into db
 2019-05-15 09:28:40 +08:00
judy0131 760a564c19 add terminal project api 2019-05-10 18:03:28 +08:00
judy0131 33e4561072 add terminal flowGroup API 2019-05-09 17:38:19 +08:00
judy0131 f36dd9cf64 optimize code 2019-05-08 11:17:01 +08:00
judy0131 da63af8562 add FlowLauncher 2019-05-08 11:01:49 +08:00
judy0131 7deb8946c7 support run project API 2019-05-05 15:34:35 +08:00
judy0131 1754a233cd 1.add json util 
2. fix bug: launch spark application for each flow in FlowGroup
 2019-04-30 16:29:22 +08:00
judy0131 76fa9280c2 support run FlowGroup API 2019-04-26 18:02:54 +08:00
judy0131 836e599c7a optimize condition for project and flowgroup 2019-04-25 14:15:52 +08:00
judy0131 c996bc72c0 1.support the execution of project which include FlowGroups and Flows 
2.the code need to be optimized!!!
 2019-04-19 16:46:46 +08:00
judy0131 a0764ceb68 1. modify show data function 
2. fix bug: when more than 5 requests of starting flow are posted, piflow server will get exception:No element passed in the last 1 minute
 2019-03-27 15:09:34 +08:00
judy0131 4080568461 fix spelling mistakes 2019-03-21 16:48:33 +08:00
judy0131 cd615ad58e set batchDuration from streamingStop 2019-03-01 16:16:25 +08:00
judy0131 c28fee4c1e support kafka streaming 2019-02-28 11:00:21 +08:00
judy0131 3d54df81f4 support streaming 2019-02-20 18:37:23 +08:00
judy0131 dd09d8c6d1 fix bug: jdbcRead stop's properties repeat 2019-01-30 10:41:28 +08:00
judy0131 081a15663b monitor the throughput of flow 2019-01-24 15:32:07 +08:00
judy0131 2ef86d8097 iptimize code 2019-01-23 14:17:34 +08:00
judy0131 b48ff0bfc2 show flow debug data by path 2019-01-23 11:27:05 +08:00
judy0131 1fe9f009e1 fix bug: when stop flow, the end time do not show 2019-01-15 15:23:29 +08:00
judy0131 9cba0f2e6e show dataFrame when job is completed 2019-01-14 16:54:22 +08:00
judy0131 212f60479a fix stop flow bug 2018-12-14 18:12:21 +08:00
judy0131 04b8992a89 fix progress bug 2018-12-07 14:03:18 +08:00
judy0131 5914c981a9 fix progress bug 2018-12-05 18:33:45 +08:00
judy0131 8b109c6902 fix bug: remove hive-site.xml core-site.xml 2018-11-30 17:07:19 +08:00
judy0131 972f8af248 fix flow progress bug 2018-11-28 18:17:39 +08:00
judy0131 420477fe45 add progress in flow info 2018-11-28 16:52:58 +08:00
judy0131 808a8e1693 fix checkpoint bug 2018-11-28 15:02:52 +08:00
judy0131 7449cbf1dc fix bug: get flow progress using checkpoint 2018-11-21 11:26:45 +08:00
judy0131 dd11c444a2 1.implement checkpoint 2018-11-20 16:46:47 +08:00
judy0131 82c64aabae add flow name in flowImpl 2018-11-06 17:07:13 +08:00
judy0131 a4badc9703 1.modify getFlowProgress api 
2.add maven-install-plugin to install the databricks file
 2018-11-06 13:55:28 +08:00
judy0131 165965fda4 modify log 2018-10-25 14:01:49 +08:00