Commit 6259716
authored
Revert "[Feature] JobState component in launcher module"
1 parent 7123bcc commit 6259716
83 files changed
Lines changed: 192 additions & 1146 deletions
File tree
- assembly
- db
- streamis-appconn
- src/main
- assembly
- java/com/webank/wedatasphere/streamis/dss/appconn
- structure
- project
- ref
- utils
- resources
- streamis-jobmanager
- streamis-job-launcher
- streamis-job-launcher-base
- src/main
- java/com/webank/wedatasphere/streamis/jobmanager/launcher/dao
- impl
- scala/com/webank/wedatasphere/streamis/jobmanager/launcher/job
- manager
- state
- streamis-job-launcher-linkis
- src/main
- java/com/webank/wedatasphere/streamis/jobmanager/launcher/linkis/job/state
- scala/com/webank/wedatasphere/streamis/jobmanager/launcher/linkis
- entity
- job/state
- manager
- streamis-job-launcher-service
- src/main/scala/com/webank/wedatasphere/streamis/jobmanager/launcher/service
- streamis-job-manager
- streamis-job-manager-base
- src/main/java/com/webank/wedatasphere/streamis/jobmanager/manager
- dao/impl
- util
- streamis-job-manager-service
- src/main
- java/com/webank/wedatasphere/streamis/jobmanager/manager/alert
- scala/com/webank/wedatasphere/streamis/jobmanager/manager
- conf
- service
- transform
- entity
- impl
- parser
- utils
- streamis-jobmanager-common
- streamis-jobmanager-server
- src/main/java/com/webank/wedatasphere/streamis/jobmanager/restful/api
- streamis-projectmanager-server
- streamis-project
- streamis-project-common
- streamis-project-server
- src/main
- java/com/webank/wedatasphere/streamis/project/server
- dao
- impl
- entity
- request
- restful
- service
- impl
- scala/com/webank/wedatasphere/streamis/project/server/receiver
- streamis-server
- web/src/apps/streamis/module/jobConfig
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
23 | | - | |
| 23 | + | |
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
34 | | - | |
| 34 | + | |
35 | 35 | | |
36 | | - | |
| 36 | + | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
40 | | - | |
| 39 | + | |
| 40 | + | |
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
| |||
129 | 129 | | |
130 | 130 | | |
131 | 131 | | |
132 | | - | |
133 | | - | |
| 132 | + | |
| 133 | + | |
134 | 134 | | |
135 | 135 | | |
136 | 136 | | |
| |||
182 | 182 | | |
183 | 183 | | |
184 | 184 | | |
185 | | - | |
| 185 | + | |
186 | 186 | | |
187 | 187 | | |
188 | 188 | | |
| |||
211 | 211 | | |
212 | 212 | | |
213 | 213 | | |
214 | | - | |
| 214 | + | |
215 | 215 | | |
216 | 216 | | |
217 | 217 | | |
218 | 218 | | |
219 | 219 | | |
220 | 220 | | |
221 | | - | |
| 221 | + | |
222 | 222 | | |
223 | 223 | | |
224 | 224 | | |
| |||
239 | 239 | | |
240 | 240 | | |
241 | 241 | | |
242 | | - | |
243 | | - | |
244 | | - | |
245 | | - | |
246 | | - | |
247 | | - | |
248 | | - | |
249 | | - | |
250 | | - | |
251 | | - | |
252 | | - | |
253 | 242 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| |||
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
45 | 44 | | |
46 | 45 | | |
47 | 46 | | |
48 | | - | |
49 | | - | |
50 | | - | |
| 47 | + | |
| 48 | + | |
51 | 49 | | |
52 | 50 | | |
53 | 51 | | |
| |||
69 | 67 | | |
70 | 68 | | |
71 | 69 | | |
72 | | - | |
| 70 | + | |
73 | 71 | | |
74 | 72 | | |
75 | 73 | | |
| |||
This file was deleted.
This file was deleted.
Lines changed: 0 additions & 30 deletions
This file was deleted.
Lines changed: 0 additions & 20 deletions
This file was deleted.
Lines changed: 0 additions & 49 deletions
This file was deleted.
0 commit comments