apache / streampark
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,486 files with 117,903 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 6 files changed 51-100 times (1,843 lines of code)
    • 47 files changed 21-50 times (11,189 lines of code)
    • 379 files changed 6-20 times (41,497 lines of code)
    • 1,054 files changed 1-5 times (63,374 lines of code)
0% | 1% | 9% | 35% | 53%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,486 files with 117,903 lines of code.
    • 1 file changed by more than 25 contributors (20 lines of code)
    • 36 files changed by 11-25 contributors (9,754 lines of code)
    • 121 files changed by 6-10 contributors (13,603 lines of code)
    • 1,041 files changed by 2-5 contributors (77,412 lines of code)
    • 287 files changed by 1 contributor (17,114 lines of code)
<1% | 8% | 11% | 65% | 14%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, ts, scala, vue, txt, xml, svg, less, yaml, tsx, sql, sh, md, js, json, ftl, properties, gitignore, editorconfig, cmd, gitattributes, stylelintignore, html, npmrc, tpl, gitmodules, eslintignore, prettierignore
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 3% | 11% | 47% | 37%
sql0% | 19% | 44% | 26% | 9%
scala0% | 0% | 9% | 57% | 32%
ts0% | 0% | 7% | 16% | 76%
vue0% | 0% | 4% | 20% | 74%
tsx0% | 0% | 15% | 38% | 45%
xml0% | 0% | 9% | 42% | 48%
ftl0% | 0% | 0% | 100% | 0%
less0% | 0% | 0% | 22% | 77%
yaml0% | 0% | 0% | 42% | 57%
js0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
streampark-console0% | 1% | 9% | 30% | 58%
streampark-flink0% | 0% | 7% | 51% | 40%
streampark-common0% | 0% | 13% | 69% | 17%
streampark-spark0% | 0% | 0% | 41% | 58%
streampark-e2e0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ProjectServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 419 22 2022-09-04 2025-01-18 67 23 benjobs@apache.org benjobs@apache.org
FlinkClusterServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 379 24 2022-09-04 2025-01-18 66 19 benjobs@apache.org benjobs@apache.org
Application.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 20 - 2022-09-04 2024-10-03 62 26 benjobs@apache.org benjobs@apache.org
data-h2.sql
in streampark-console/streampark-console-service/src/main/resources/db
 280 - 2022-09-04 2025-01-18 59 17 benjobs@apache.org benjobs@apache.org
schema-h2.sql
in streampark-console/streampark-console-service/src/main/resources/db
 509 - 2022-09-04 2025-03-30 57 20 benjobs@apache.org 48339061+aalron@users.norep...
UserServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 236 18 2022-09-04 2025-01-18 52 17 benjobs@apache.org benjobs@apache.org
app.ts
in streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink
 309 - 2022-11-11 2025-01-20 45 10 benjobs@apache.org mr.artboy@gmail.com
app.ts
in streampark-console/streampark-console-webapp/src/locales/lang/en/flink
 321 - 2022-11-11 2025-01-20 44 12 benjobs@apache.org zhilinli0706@gmail.com
EnvInitializer.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner
 200 11 2022-09-04 2024-12-01 43 18 benjobs@apache.org benjobs@apache.org
ResourceServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 443 25 2023-05-03 2025-01-18 42 20 zhouli.dev@foxmail.com benjobs@apache.org
FlinkClientTrait.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait
 501 22 2023-02-27 2025-02-11 42 13 benjobs@apache.org benjobs@apache.org
mysql-schema.sql
in streampark-console/streampark-console-service/src/main/assembly/script/schema
 566 - 2022-12-19 2025-03-30 42 17 benjobs@apache.org 48339061+aalron@users.norep...
FlinkCluster.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 136 7 2022-09-04 2024-10-03 41 14 benjobs@apache.org benjobs@apache.org
ApplicationMapper.xml
in streampark-console/streampark-console-service/src/main/resources/mapper/core
 4 - 2022-09-04 2024-09-27 39 14 benjobs@apache.org benjobs@apache.org
pgsql-schema.sql
in streampark-console/streampark-console-service/src/main/assembly/script/schema
 695 - 2022-12-19 2025-03-30 39 16 benjobs@apache.org 48339061+aalron@users.norep...
useCreateAndEditSchema.ts
in streampark-console/streampark-console-webapp/src/views/flink/app/hooks
 613 56 2022-11-11 2025-01-22 38 13 benjobs@apache.org benjobs@apache.org
Project.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 216 13 2022-09-04 2024-09-24 36 18 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 409 - 2022-09-04 2025-01-20 35 14 benjobs@apache.org mr.artboy@gmail.com
FlinkSqlServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 186 13 2022-09-04 2025-01-18 33 14 benjobs@apache.org benjobs@apache.org
EditStreamPark.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 404 - 2022-09-04 2025-01-22 32 11 benjobs@apache.org benjobs@apache.org
TeamServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 112 7 2022-10-07 2025-01-18 31 12 1996fanrui@gmail.com benjobs@apache.org
FlinkEnvServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 133 12 2022-09-04 2025-01-18 31 17 benjobs@apache.org benjobs@apache.org
mysql-data.sql
in streampark-console/streampark-console-service/src/main/assembly/script/data
 273 - 2022-12-19 2025-01-18 31 14 benjobs@apache.org benjobs@apache.org
SubmitRequest.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean
 174 2 2023-02-08 2025-01-19 30 11 benjobs@apache.org mr.artboy@gmail.com
FlinkJobStatusWatcher.scala
in streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher
 427 17 2022-09-04 2024-09-27 30 8 benjobs@apache.org benjobs@apache.org
RoleServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 96 7 2022-09-04 2025-01-18 29 13 benjobs@apache.org benjobs@apache.org
UserController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller
 111 11 2022-09-04 2024-08-04 29 9 benjobs@apache.org benjobs@apache.org
VariableServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 186 14 2022-10-17 2025-01-18 29 11 305343894@qq.com benjobs@apache.org
Add.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 355 - 2022-09-04 2025-01-22 29 13 benjobs@apache.org benjobs@apache.org
pgsql-data.sql
in streampark-console/streampark-console-service/src/main/assembly/script/data
 247 - 2022-12-19 2025-01-18 28 13 benjobs@apache.org benjobs@apache.org
YarnApplicationClient.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl
 108 2 2023-02-27 2025-04-24 27 12 benjobs@apache.org mr.artboy@gmail.com
MemberServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 118 12 2022-10-11 2025-01-18 27 11 benjobs@apache.org benjobs@apache.org
flinkEnum.ts
in streampark-console/streampark-console-webapp/src/enums
 146 - 2022-11-11 2025-01-20 27 10 benjobs@apache.org mr.artboy@gmail.com
useFlinkRender.tsx
in streampark-console/streampark-console-webapp/src/views/flink/app/hooks
 673 12 2022-11-11 2024-09-27 27 8 benjobs@apache.org benjobs@apache.org
AccessTokenServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 81 4 2022-09-04 2024-08-04 26 10 benjobs@apache.org benjobs@apache.org
MenuServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 99 3 2022-09-04 2025-01-12 26 12 benjobs@apache.org benjobs@apache.org
FlinkAppHttpWatcher.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher
 655 36 2023-09-25 2024-12-20 25 12 benjobs@apache.org 70357858+forus0322@users.no...
Utils.scala
in streampark-common/src/main/scala/org/apache/streampark/common/util
 128 9 2022-09-04 2025-02-11 24 11 benjobs@apache.org benjobs@apache.org
ProjectController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller
 129 14 2022-09-04 2024-09-24 24 9 benjobs@apache.org benjobs@apache.org
FileUtils.scala
in streampark-common/src/main/scala/org/apache/streampark/common/util
 233 19 2022-09-04 2024-07-20 24 5 benjobs@apache.org benjobs@apache.org
ApplicationMapper.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper
 5 - 2022-09-04 2024-09-27 23 8 benjobs@apache.org benjobs@apache.org
PassportController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller
 78 3 2022-09-04 2024-08-04 23 11 benjobs@apache.org benjobs@apache.org
useAppTableAction.ts
in streampark-console/streampark-console-webapp/src/views/flink/app/hooks
 322 23 2022-11-11 2025-01-22 23 6 1246458990@qq.com benjobs@apache.org
UserService.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service
 30 - 2022-09-04 2024-08-04 22 8 benjobs@apache.org benjobs@apache.org
FlinkShimsProxy.scala
in streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy
 146 9 2022-09-04 2024-09-04 22 8 benjobs@apache.org 65238551+hxpserein@users.no...
YarnQueueServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 190 13 2023-03-18 2025-01-18 22 10 flinker@126.com benjobs@apache.org
ProjectMapper.xml
in streampark-console/streampark-console-service/src/main/resources/mapper/core
 4 - 2022-09-04 2025-01-18 21 8 benjobs@apache.org benjobs@apache.org
FlinkClusterService.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service
 26 - 2022-09-04 2024-09-27 21 10 benjobs@apache.org benjobs@apache.org
UserMapper.xml
in streampark-console/streampark-console-service/src/main/resources/mapper/system
 84 - 2022-09-04 2025-01-18 21 7 benjobs@apache.org benjobs@apache.org
AuthenticatorImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl
 87 5 2022-10-18 2024-08-09 21 13 60029759+monsterchenzhuo@us... whushawhe@163.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
Application.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 20 - 2022-09-04 2024-10-03 62 26 benjobs@apache.org benjobs@apache.org
ProjectServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 419 22 2022-09-04 2025-01-18 67 23 benjobs@apache.org benjobs@apache.org
schema-h2.sql
in streampark-console/streampark-console-service/src/main/resources/db
 509 - 2022-09-04 2025-03-30 57 20 benjobs@apache.org 48339061+aalron@users.norep...
ResourceServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 443 25 2023-05-03 2025-01-18 42 20 zhouli.dev@foxmail.com benjobs@apache.org
FlinkClusterServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 379 24 2022-09-04 2025-01-18 66 19 benjobs@apache.org benjobs@apache.org
EnvInitializer.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner
 200 11 2022-09-04 2024-12-01 43 18 benjobs@apache.org benjobs@apache.org
Project.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 216 13 2022-09-04 2024-09-24 36 18 benjobs@apache.org benjobs@apache.org
data-h2.sql
in streampark-console/streampark-console-service/src/main/resources/db
 280 - 2022-09-04 2025-01-18 59 17 benjobs@apache.org benjobs@apache.org
UserServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 236 18 2022-09-04 2025-01-18 52 17 benjobs@apache.org benjobs@apache.org
mysql-schema.sql
in streampark-console/streampark-console-service/src/main/assembly/script/schema
 566 - 2022-12-19 2025-03-30 42 17 benjobs@apache.org 48339061+aalron@users.norep...
FlinkEnvServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 133 12 2022-09-04 2025-01-18 31 17 benjobs@apache.org benjobs@apache.org
pgsql-schema.sql
in streampark-console/streampark-console-service/src/main/assembly/script/schema
 695 - 2022-12-19 2025-03-30 39 16 benjobs@apache.org 48339061+aalron@users.norep...
FlinkCluster.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 136 7 2022-09-04 2024-10-03 41 14 benjobs@apache.org benjobs@apache.org
ApplicationMapper.xml
in streampark-console/streampark-console-service/src/main/resources/mapper/core
 4 - 2022-09-04 2024-09-27 39 14 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 409 - 2022-09-04 2025-01-20 35 14 benjobs@apache.org mr.artboy@gmail.com
FlinkSqlServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 186 13 2022-09-04 2025-01-18 33 14 benjobs@apache.org benjobs@apache.org
mysql-data.sql
in streampark-console/streampark-console-service/src/main/assembly/script/data
 273 - 2022-12-19 2025-01-18 31 14 benjobs@apache.org benjobs@apache.org
FlinkClientTrait.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait
 501 22 2023-02-27 2025-02-11 42 13 benjobs@apache.org benjobs@apache.org
useCreateAndEditSchema.ts
in streampark-console/streampark-console-webapp/src/views/flink/app/hooks
 613 56 2022-11-11 2025-01-22 38 13 benjobs@apache.org benjobs@apache.org
Add.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 355 - 2022-09-04 2025-01-22 29 13 benjobs@apache.org benjobs@apache.org
RoleServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 96 7 2022-09-04 2025-01-18 29 13 benjobs@apache.org benjobs@apache.org
pgsql-data.sql
in streampark-console/streampark-console-service/src/main/assembly/script/data
 247 - 2022-12-19 2025-01-18 28 13 benjobs@apache.org benjobs@apache.org
AuthenticatorImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl
 87 5 2022-10-18 2024-08-09 21 13 60029759+monsterchenzhuo@us... whushawhe@163.com
ExternalLinkServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 83 6 2023-02-28 2025-01-12 18 13 282130830@qq.com benjobs@apache.org
app.ts
in streampark-console/streampark-console-webapp/src/locales/lang/en/flink
 321 - 2022-11-11 2025-01-20 44 12 benjobs@apache.org zhilinli0706@gmail.com
TeamServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 112 7 2022-10-07 2025-01-18 31 12 1996fanrui@gmail.com benjobs@apache.org
YarnApplicationClient.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl
 108 2 2023-02-27 2025-04-24 27 12 benjobs@apache.org mr.artboy@gmail.com
MenuServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 99 3 2022-09-04 2025-01-12 26 12 benjobs@apache.org benjobs@apache.org
FlinkAppHttpWatcher.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher
 655 36 2023-09-25 2024-12-20 25 12 benjobs@apache.org 70357858+forus0322@users.no...
FlinkK8sApplicationBuildPipeline.scala
in streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl
 209 3 2022-09-04 2025-02-19 18 12 benjobs@apache.org ma_lihe@163.com
EditStreamPark.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 404 - 2022-09-04 2025-01-22 32 11 benjobs@apache.org benjobs@apache.org
SubmitRequest.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean
 174 2 2023-02-08 2025-01-19 30 11 benjobs@apache.org mr.artboy@gmail.com
VariableServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 186 14 2022-10-17 2025-01-18 29 11 305343894@qq.com benjobs@apache.org
MemberServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 118 12 2022-10-11 2025-01-18 27 11 benjobs@apache.org benjobs@apache.org
Utils.scala
in streampark-common/src/main/scala/org/apache/streampark/common/util
 128 9 2022-09-04 2025-02-11 24 11 benjobs@apache.org benjobs@apache.org
PassportController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller
 78 3 2022-09-04 2024-08-04 23 11 benjobs@apache.org benjobs@apache.org
FlinkSqlController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller
 96 6 2022-09-04 2024-09-27 19 11 benjobs@apache.org benjobs@apache.org
app.ts
in streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink
 309 - 2022-11-11 2025-01-20 45 10 benjobs@apache.org mr.artboy@gmail.com
flinkEnum.ts
in streampark-console/streampark-console-webapp/src/enums
 146 - 2022-11-11 2025-01-20 27 10 benjobs@apache.org mr.artboy@gmail.com
AccessTokenServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl
 81 4 2022-09-04 2024-08-04 26 10 benjobs@apache.org benjobs@apache.org
YarnQueueServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 190 13 2023-03-18 2025-01-18 22 10 flinker@126.com benjobs@apache.org
Detail.vue
in streampark-console/streampark-console-webapp/src/views/flink/app
 192 - 2022-09-04 2024-09-27 21 10 benjobs@apache.org benjobs@apache.org
FlinkClusterService.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service
 26 - 2022-09-04 2024-09-27 21 10 benjobs@apache.org benjobs@apache.org
ProjectBuildTask.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task
 183 9 2022-09-29 2024-09-24 21 10 1996fanrui@gmail.com benjobs@apache.org
LoginForm.vue
in streampark-console/streampark-console-webapp/src/views/base/login
 200 - 2022-11-11 2024-09-26 19 10 benjobs@apache.org 39726513+wangsizhu0504@user...
2.2.0.sql
in streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql
 109 - 2023-05-03 2025-03-30 19 10 zhouli.dev@foxmail.com 48339061+aalron@users.norep...
KubernetesNativeClientTrait.scala
in streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait
 136 9 2023-02-27 2024-09-27 17 10 benjobs@apache.org benjobs@apache.org
UserController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller
 111 11 2022-09-04 2024-08-04 29 9 benjobs@apache.org benjobs@apache.org
ProjectController.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller
 129 14 2022-09-04 2024-09-24 24 9 benjobs@apache.org benjobs@apache.org
index.ts
in streampark-console/streampark-console-webapp/src/views/flink/app/utils
 264 17 2022-11-11 2024-09-27 20 9 benjobs@apache.org benjobs@apache.org
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FlinkApplicationInfoServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl
 416 27 2024-09-27 2025-01-18 4 1 benjobs@apache.org benjobs@apache.org
Murmur3Hash.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util
 372 22 2024-09-11 2024-09-11 1 1 65238551+hxpserein@users.no... 65238551+hxpserein@users.no...
PaginationInterceptor.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/interceptor
 341 13 2025-01-18 2025-01-18 1 1 benjobs@apache.org benjobs@apache.org
PomTemplateTab.vue
in streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate
 287 - 2022-11-11 2023-10-15 2 1 benjobs@apache.org benjobs@apache.org
AlertModal.vue
in streampark-console/streampark-console-webapp/src/views/setting/alarm/components
 285 - 2024-03-14 2024-09-21 2 1 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/setting/alarm
 283 - 2024-03-14 2025-04-11 3 1 benjobs@apache.org benjobs@apache.org
ApplicationBuildPipeline.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity
 275 17 2024-10-03 2024-10-03 1 1 benjobs@apache.org benjobs@apache.org
TableServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl
 261 11 2024-10-02 2024-10-02 1 1 mr.artboy@gmail.com mr.artboy@gmail.com
UploadDrawer.vue
in streampark-console/streampark-console-webapp/src/views/resource/upload/components
 259 - 2023-10-15 2024-09-21 6 1 benjobs@apache.org benjobs@apache.org
Upload.vue
in streampark-console/streampark-console-webapp/src/views/resource/upload/components
 244 - 2023-10-15 2024-09-06 3 1 benjobs@apache.org benjobs@apache.org
FlinkCatalogBase.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service
 244 13 2024-10-02 2024-10-02 1 1 mr.artboy@gmail.com mr.artboy@gmail.com
ListItem.vue
in streampark-console/streampark-console-webapp/src/views/resource/project/components
 242 - 2023-10-15 2023-11-30 2 1 benjobs@apache.org benjobs@apache.org
FlinkApplicationMapper.xml
in streampark-console/streampark-console-service/src/main/resources/mapper/core
 240 - 2024-09-27 2025-01-18 2 1 benjobs@apache.org benjobs@apache.org
SparkApplicationConfigServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl
 222 15 2024-09-27 2025-01-18 5 1 benjobs@apache.org benjobs@apache.org
SparkK8sApplicationBuildPipeline.scala
in streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl
 190 3 2024-11-29 2024-11-29 1 1 66543456+lenoxzhao@users.no... 66543456+lenoxzhao@users.no...
index.tsx
in streampark-console/streampark-console-webapp/src/components/OpenApi/src
 190 4 2024-07-25 2024-07-26 2 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
RespContent.java
in streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean
 189 36 2022-09-04 2023-04-15 3 1 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/system/user
 188 - 2023-10-15 2024-09-24 4 1 benjobs@apache.org benjobs@apache.org
Mergely.vue
in streampark-console/streampark-console-webapp/src/views/flink/app/components
 176 - 2022-11-11 2022-11-11 1 1 benjobs@apache.org benjobs@apache.org
VariableModal.vue
in streampark-console/streampark-console-webapp/src/views/resource/variable/components
 175 - 2024-09-21 2024-09-21 1 1 benjobs@apache.org benjobs@apache.org
Mergely.vue
in streampark-console/streampark-console-webapp/src/views/spark/app/components
 170 - 2024-08-24 2024-08-24 1 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
View.vue
in streampark-console/streampark-console-webapp/src/views/system/member
 169 - 2023-10-15 2024-09-24 4 1 benjobs@apache.org benjobs@apache.org
OpenAPIComponent.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component
 169 5 2024-07-24 2024-08-04 3 1 benjobs@apache.org benjobs@apache.org
index.data.ts
in streampark-console/streampark-console-webapp/src/views/setting/alarm/components
 166 27 2024-03-14 2024-03-14 1 1 benjobs@apache.org benjobs@apache.org
index.ts
in streampark-console/streampark-console-webapp/src/views/spark/app/utils
 162 10 2024-09-03 2024-09-14 2 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
SparkApplicationBackupServiceImpl.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl
 161 7 2024-10-03 2025-01-20 4 1 benjobs@apache.org benjobs@apache.org
SettingList.vue
in streampark-console/streampark-console-webapp/src/views/setting/system
 153 - 2024-03-14 2024-03-14 1 1 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/setting/system
 153 - 2024-03-14 2024-09-21 2 1 benjobs@apache.org benjobs@apache.org
DataTypeConverterUtils.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util
 148 2 2024-10-02 2024-10-02 1 1 mr.artboy@gmail.com mr.artboy@gmail.com
View.vue
in streampark-console/streampark-console-webapp/src/views/system/role
 147 - 2023-10-15 2024-09-24 4 1 benjobs@apache.org benjobs@apache.org
SettingForm.vue
in streampark-console/streampark-console-webapp/src/views/setting/system
 145 - 2024-03-14 2024-03-14 1 1 benjobs@apache.org benjobs@apache.org
SparkSqlCompareModal.vue
in streampark-console/streampark-console-webapp/src/views/spark/app/components
 143 - 2024-09-03 2024-09-03 1 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
View.vue
in streampark-console/streampark-console-webapp/src/views/system/token
 141 - 2023-10-15 2024-09-24 4 1 benjobs@apache.org benjobs@apache.org
JdbcCatalogStore.java
in streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog
 138 9 2024-07-31 2024-07-31 1 1 mr.artboy@gmail.com mr.artboy@gmail.com
MemberModal.vue
in streampark-console/streampark-console-webapp/src/views/system/member
 138 - 2024-09-21 2024-09-21 1 1 benjobs@apache.org benjobs@apache.org
DetailModal.vue
in streampark-console/streampark-console-webapp/src/views/setting/alarm/components
 137 - 2024-03-14 2024-03-14 1 1 benjobs@apache.org benjobs@apache.org
YarnQueueModal.vue
in streampark-console/streampark-console-webapp/src/views/setting/yarn-queue
 136 - 2024-09-21 2024-09-21 1 1 benjobs@apache.org benjobs@apache.org
View.vue
in streampark-console/streampark-console-webapp/src/views/system/team
 131 - 2023-10-15 2024-09-24 4 1 benjobs@apache.org benjobs@apache.org
CompareModal.vue
in streampark-console/streampark-console-webapp/src/views/spark/app/components
 131 - 2024-09-03 2024-09-03 1 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
useLog.ts
in streampark-console/streampark-console-webapp/src/hooks/web
 131 4 2023-10-15 2023-10-15 1 1 benjobs@apache.org benjobs@apache.org
app.ts
in streampark-console/streampark-console-webapp/src/api/flink
 127 23 2023-10-15 2024-08-04 6 1 benjobs@apache.org benjobs@apache.org
AppResize.vue
in streampark-console/streampark-console-webapp/src/views/flink/app/components
 125 - 2024-01-30 2024-09-09 2 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
HostAliasDrawer.vue
in streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate
 117 - 2022-11-11 2023-10-15 2 1 benjobs@apache.org benjobs@apache.org
FlinkSqlDifferent.vue
in streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail
 117 - 2023-03-07 2023-03-07 1 1 zhouli.dev@foxmail.com zhouli.dev@foxmail.com
View.vue
in streampark-console/streampark-console-webapp/src/views/flink/gateway
 115 - 2023-10-15 2023-10-15 1 1 benjobs@apache.org benjobs@apache.org
SparkSqlDifferent.vue
in streampark-console/streampark-console-webapp/src/views/spark/app/components
 111 - 2024-09-03 2024-09-24 2 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
VariableInfo.vue
in streampark-console/streampark-console-webapp/src/views/resource/variable/components
 110 - 2023-10-15 2024-09-21 2 1 benjobs@apache.org benjobs@apache.org
AlertTemplateUtils.java
in streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util
 110 5 2024-12-20 2024-12-20 1 1 70357858+forus0322@users.no... 70357858+forus0322@users.no...
ProgramArgs.vue
in streampark-console/streampark-console-webapp/src/views/spark/app/components
 109 - 2024-08-24 2024-09-24 2 1 39726513+wangsizhu0504@user... 39726513+wangsizhu0504@user...
JdbcConnectionOptions.java
in streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog/connections
 105 15 2024-07-31 2024-07-31 1 1 mr.artboy@gmail.com mr.artboy@gmail.com
Correlations

File Size vs. Number of Changes: 1503 points

streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala x: 165 lines of code y: 17 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala x: 108 lines of code y: 27 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DistributedTaskServiceImpl.java x: 211 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/components/Application/src/AppDarkModeToggle.vue x: 70 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/components/ContextMenu/src/ContextMenu.vue x: 186 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/components/Form/src/BasicForm.vue x: 319 lines of code y: 12 # changes streampark-console/streampark-console-webapp/src/components/Page/src/PageFooter.vue x: 49 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/components/Table/src/components/HeaderCell.vue x: 44 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/hooks/web/useLockPage.ts x: 62 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/router/guard/permissionGuard.ts x: 85 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/router/routes/basic.ts x: 74 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/utils/props.ts x: 141 lines of code y: 14 # changes streampark-console/streampark-console-webapp/src/views/setting/alarm/View.vue x: 283 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql x: 566 lines of code y: 42 # changes streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql x: 695 lines of code y: 39 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql x: 109 lines of code y: 19 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql x: 16 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java x: 26 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationLogServiceImpl.java x: 37 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java x: 784 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java x: 620 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java x: 672 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java x: 461 lines of code y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java x: 483 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java x: 390 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql x: 509 lines of code y: 57 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala x: 101 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java x: 131 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/api/system/token.ts x: 25 lines of code y: 4 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala x: 209 lines of code y: 18 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala x: 128 lines of code y: 24 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java x: 17 lines of code y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java x: 37 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/resources/alert-template/alert-dingTalk.ftl x: 54 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/resources/alert-template/alert-lark.ftl x: 273 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/resources/alert-template/alert-weCom.ftl x: 49 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/layouts/default/footer/index.vue x: 115 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/Github.vue x: 28 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/sys.ts x: 115 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/sys.ts x: 108 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/settings/siteSetting.ts x: 5 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/utils/http/axios/helper.ts x: 89 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/base/login/LoginSlogan.tsx x: 76 lines of code y: 5 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala x: 501 lines of code y: 42 # changes streampark-console/streampark-console-webapp/src/views/flink/app/Add.vue x: 355 lines of code y: 29 # changes streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue x: 404 lines of code y: 32 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/FlinkSql.vue x: 275 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts x: 118 lines of code y: 14 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts x: 322 lines of code y: 23 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts x: 613 lines of code y: 38 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateSchema.ts x: 285 lines of code y: 18 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEditStreamPark.ts x: 175 lines of code y: 12 # changes streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts x: 146 lines of code y: 27 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts x: 321 lines of code y: 44 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts x: 309 lines of code y: 45 # changes streampark-console/streampark-console-webapp/src/views/flink/app/View.vue x: 409 lines of code y: 35 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java x: 46 lines of code y: 9 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkJobType.java x: 29 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java x: 439 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java x: 363 lines of code y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/ResourceFromEnum.java x: 15 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBackupServiceImpl.java x: 160 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationConfigServiceImpl.java x: 213 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBackupServiceImpl.java x: 161 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java x: 539 lines of code y: 20 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/ExecOptionModal.vue x: 90 lines of code y: 2 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala x: 174 lines of code y: 30 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkYarnApplicationBuildPipeline.scala x: 83 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql x: 273 lines of code y: 31 # changes streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql x: 247 lines of code y: 28 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/MybatisConfig.java x: 64 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/interceptor/PaginationInterceptor.java x: 341 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkApplicationConfigMapper.java x: 8 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkApplicationMapper.java x: 23 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkCatalogMapper.java x: 5 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java x: 5 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkEnvMapper.java x: 8 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java x: 9 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ResourceMapper.java x: 9 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationMapper.java x: 16 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java x: 9 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProjectService.java x: 32 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationInfoServiceImpl.java x: 416 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationConfigServiceImpl.java x: 222 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkCatalogServiceImpl.java x: 108 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java x: 379 lines of code y: 66 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java x: 133 lines of code y: 31 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSqlServiceImpl.java x: 186 lines of code y: 33 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java x: 419 lines of code y: 67 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java x: 443 lines of code y: 42 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkSqlServiceImpl.java x: 185 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java x: 186 lines of code y: 29 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java x: 190 lines of code y: 22 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java x: 12 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java x: 5 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/TeamMapper.java x: 7 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/UserMapper.java x: 12 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java x: 118 lines of code y: 27 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java x: 96 lines of code y: 29 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java x: 112 lines of code y: 31 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java x: 236 lines of code y: 52 # changes streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql x: 280 lines of code y: 59 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkApplicationConfigMapper.xml x: 17 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkApplicationMapper.xml x: 240 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkCatalogMapper.xml x: 4 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml x: 4 lines of code y: 14 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkEnvMapper.xml x: 18 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ProjectMapper.xml x: 4 lines of code y: 21 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ResourceMapper.xml x: 29 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationConfigMapper.xml x: 17 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationMapper.xml x: 139 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/VariableMapper.xml x: 29 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/YarnQueueMapper.xml x: 4 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml x: 44 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml x: 4 lines of code y: 16 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml x: 84 lines of code y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/ServiceHelper.java x: 95 lines of code y: 2 # changes streampark-flink/streampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCClient.java x: 50 lines of code y: 1 # changes streampark-flink/streampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCExecutor.java x: 41 lines of code y: 1 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala x: 200 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java x: 252 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java x: 83 lines of code y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEffectiveServiceImpl.java x: 56 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkEffectiveServiceImpl.java x: 58 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkEnvServiceImpl.java x: 101 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java x: 99 lines of code y: 26 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java x: 18 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java x: 38 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/LdapService.java x: 85 lines of code y: 9 # changes streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/ParameterTool.java x: 48 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java x: 181 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/AlertTemplateUtils.java x: 110 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java x: 655 lines of code y: 25 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java x: 198 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java x: 131 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java x: 271 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala x: 174 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationController.java x: 235 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java x: 101 lines of code y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/WebUtils.java x: 59 lines of code y: 14 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/AlertConfigMapper.java x: 5 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java x: 200 lines of code y: 43 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/DistributedTaskService.java x: 14 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/AlertConfigServiceImpl.java x: 58 lines of code y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/RegistryServiceImpl.java x: 164 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java x: 215 lines of code y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleMenuServiceImpl.java x: 30 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/AlertConfigMapper.xml x: 4 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/app.ts x: 287 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/PodTemplateTool.scala x: 68 lines of code y: 5 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/SparkK8sPodTemplates.scala x: 34 lines of code y: 1 # changes streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/PipelineTypeEnum.java x: 118 lines of code y: 6 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/SparkDockerfileTemplate.scala x: 16 lines of code y: 1 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/SparkDockerfileTemplateTrait.scala x: 58 lines of code y: 1 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/SparkHadoopDockerfileTemplate.scala x: 81 lines of code y: 1 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/BuildRequest.scala x: 107 lines of code y: 15 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkK8sApplicationBuildPipeline.scala x: 190 lines of code y: 1 # changes streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/SparkClient.scala x: 40 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/assembly/conf/config.yaml x: 60 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/RegistryService.java x: 5 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql x: 109 lines of code y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java x: 59 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java x: 13 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java x: 17 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java x: 50 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/VueRouter.java x: 31 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/entity/BaseEntity.java x: 16 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertConfigParams.java x: 60 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertEmailParams.java x: 13 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertHttpCallbackParams.java x: 16 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java x: 16 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java x: 19 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertProbeMsg.java x: 33 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java x: 115 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/DockerConfig.java x: 32 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java x: 41 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/FlinkCatalogParams.java x: 137 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/FlinkConnector.java x: 12 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenConfig.java x: 52 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java x: 36 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java x: 10 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SparkTaskItem.java x: 10 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkConfigController.java x: 60 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkPipelineController.java x: 47 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java x: 210 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkPipelineController.java x: 43 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java x: 64 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java x: 20 lines of code y: 62 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBuildPipeline.java x: 275 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/DistributedTask.java x: 21 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java x: 27 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplicationConfig.java x: 104 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java x: 136 lines of code y: 41 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java x: 125 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java x: 88 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java x: 32 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java x: 28 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationBackup.java x: 53 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationConfig.java x: 57 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkEnv.java x: 97 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkSql.java x: 73 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java x: 37 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java x: 26 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ApplicationBuildPipelineMapper.java x: 5 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationBackUpMapper.java x: 5 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java x: 88 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/spark/Job.java x: 30 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/spark/SparkExecutor.java x: 11 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/yarn/YarnAppInfo.java x: 42 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/QuickStartRunner.java x: 66 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/FlinkApplicationBackupService.java x: 17 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ApplicationBackUpCleanTask.java x: 44 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java x: 38 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java x: 23 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java x: 17 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java x: 22 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java x: 57 lines of code y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/JacksonUtils.java x: 45 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/DatabaseParam.java x: 14 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/TableColumn.java x: 22 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/TableParams.java x: 26 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkCatalogController.java x: 64 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/TableController.java x: 103 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/DatabaseMapper.java x: 7 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/DatabaseService.java x: 11 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkCatalogBase.java x: 244 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkCatalogService.java x: 14 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DatabaseServiceImpl.java x: 95 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/TableServiceImpl.java x: 261 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/DataTypeConverterUtils.java x: 148 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/resources/config.yaml x: 75 lines of code y: 5 # changes streampark-flink/streampark-flink-connector-plugin/src/main/java/org/apache/streampark/package-info.java x: 1 lines of code y: 1 # changes streampark-flink/streampark-flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/CompKubernetesDeployment.java x: 7 lines of code y: 4 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala x: 119 lines of code y: 15 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala x: 30 lines of code y: 8 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategy.scala x: 62 lines of code y: 10 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala x: 83 lines of code y: 11 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/K8sDeploymentEventCV.scala x: 4 lines of code y: 4 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkK8sEventWatcher.scala x: 55 lines of code y: 8 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkClientTrait.scala x: 25 lines of code y: 8 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkKubernetesClientTrait.scala x: 8 lines of code y: 3 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala x: 122 lines of code y: 18 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/SparkJobType.java x: 28 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ProxyController.java x: 97 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationBackUp.java x: 53 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProxyService.java x: 13 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationActionService.java x: 11 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java x: 218 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/api/spark/app.type.ts x: 119 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/spark/app.ts x: 294 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/spark/home.ts x: 35 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue x: 520 lines of code y: 19 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx x: 361 lines of code y: 18 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/View.vue x: 249 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/DetailTab.vue x: 449 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/State.tsx x: 207 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/spark/app/data/detail.data.ts x: 99 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/spark/app/detail.vue x: 192 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx x: 379 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts x: 303 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/spark/app/index.vue x: 393 lines of code y: 8 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkRemoteBuildPipeline.scala x: 65 lines of code y: 11 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkYarnBuildPipeline.scala x: 83 lines of code y: 1 # changes streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitRequest.scala x: 123 lines of code y: 9 # changes streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/trait/SparkClientTrait.scala x: 68 lines of code y: 7 # changes streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/proxy/SparkShimsProxy.scala x: 154 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/Workspace.scala x: 68 lines of code y: 16 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationHistoryController.java x: 67 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkConfigController.java x: 60 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ApplicationMapper.java x: 5 lines of code y: 23 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEffectiveService.java x: 10 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/FlinkApplicationConfigService.java x: 20 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBackUpServiceImpl.java x: 160 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBackUpServiceImpl.java x: 161 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ApplicationMapper.xml x: 4 lines of code y: 39 # changes streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/CancelResponse.scala x: 2 lines of code y: 2 # changes streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/SparkClientEndpoint.scala x: 27 lines of code y: 5 # changes streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/impl/YarnClient.scala x: 133 lines of code y: 5 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala x: 355 lines of code y: 21 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkDeployMode.java x: 84 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkSqlController.java x: 96 lines of code y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java x: 71 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavepointController.java x: 51 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkSqlController.java x: 96 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/VariableController.java x: 82 lines of code y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java x: 26 lines of code y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkSqlService.java x: 24 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/VariableService.java x: 19 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java x: 20 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/FlinkApplicationInfoService.java x: 36 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/FlinkApplicationManageService.java x: 29 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ApplicationLogMapper.xml x: 4 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ExternalLinkMapper.xml x: 4 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkSavepointMapper.xml x: 4 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkSqlMapper.xml x: 24 lines of code y: 12 # changes streampark-console/streampark-console-webapp/src/api/flink/app.type.ts x: 161 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/design/swal2.less x: 90 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/enums/sparkEnum.ts x: 53 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkCluster.ts x: 72 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/setting/flinkCluster.ts x: 70 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue x: 192 lines of code y: 21 # changes streampark-console/streampark-console-webapp/src/views/flink/app/EditFlink.vue x: 216 lines of code y: 19 # changes streampark-console/streampark-console-webapp/src/views/flink/app/data/index.ts x: 68 lines of code y: 14 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEdit.ts x: 102 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEditFlinkSchema.ts x: 110 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx x: 673 lines of code y: 27 # changes streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts x: 264 lines of code y: 20 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/Edit.vue x: 135 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/useClusterSetting.ts x: 382 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/spark/app/create.vue x: 137 lines of code y: 11 # changes streampark-console/streampark-console-webapp/src/views/spark/app/edit.vue x: 159 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useAppFormSchema.tsx x: 282 lines of code y: 8 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/DeployRequest.scala x: 43 lines of code y: 12 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/TriggerSavepointRequest.scala x: 17 lines of code y: 10 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientEntrypoint.scala x: 60 lines of code y: 4 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala x: 66 lines of code y: 12 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala x: 170 lines of code y: 19 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/RemoteClient.scala x: 126 lines of code y: 10 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/KubernetesNativeClientTrait.scala x: 136 lines of code y: 17 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/DefaultFlinkK8sWatcher.scala x: 113 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/ClusterKey.scala x: 24 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/TrackId.scala x: 64 lines of code y: 11 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala x: 427 lines of code y: 30 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala x: 303 lines of code y: 12 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/AppForm.vue x: 105 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/base/login/Login.vue x: 158 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/base/login/LoginForm.vue x: 200 lines of code y: 19 # changes streampark-console/streampark-console-webapp/src/views/base/login/LoginSlogan.less x: 239 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/components/Drawer/src/BasicDrawer.vue x: 221 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/BuildDrawer.vue x: 212 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/BuildDrawer.vue x: 207 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSql.vue x: 255 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkRender.tsx x: 264 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/flink/variable.ts x: 42 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/styles/Add.less x: 242 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/home.ts x: 33 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StopApplicationModal.vue x: 136 lines of code y: 18 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/ProgramArgs.vue x: 109 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSqlDifferent.vue x: 111 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSqlReview.vue x: 38 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/VariableReview.vue x: 47 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/spark/home/components/Modal.vue x: 153 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/spark/home/index.vue x: 160 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/GitUtils.java x: 215 lines of code y: 16 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/ObjectUtils.java x: 550 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java x: 216 lines of code y: 36 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java x: 183 lines of code y: 21 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkHome.ts x: 27 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue x: 85 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/flink/home/View.vue x: 181 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/home/components/Modal.vue x: 165 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/resource/project/Edit.vue x: 103 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/resource/project/View.vue x: 342 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/resource/project/useProject.tsx x: 310 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/system/member/View.vue x: 169 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/role/View.vue x: 147 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/team/View.vue x: 131 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/token/View.vue x: 141 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/user/View.vue x: 188 lines of code y: 4 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala x: 269 lines of code y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java x: 88 lines of code y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java x: 73 lines of code y: 15 # changes streampark-console/streampark-console-webapp/src/api/flink/flinkCluster.ts x: 70 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/api/flink/flinkEnv.ts x: 86 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/BasicTable.vue x: 428 lines of code y: 10 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useTableForm.ts x: 45 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Table/src/types/table.ts x: 227 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/design/index.less x: 113 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/flink/home/components/Drawer.vue x: 99 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/setting/extlink/View.vue x: 122 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/spark/home/components/Drawer.vue x: 101 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/components/Dropdown/src/Dropdown.vue x: 117 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/StatisticCard.vue x: 41 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/api/system/user.ts x: 76 lines of code y: 13 # changes streampark-console/streampark-console-webapp/src/components/Application/src/AppLogo.vue x: 80 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/design/var/index.less x: 21 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/MultipleHeader.vue x: 109 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/layouts/default/sider/LayoutSider.vue x: 185 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/system/role.ts x: 21 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/system/member.ts x: 20 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/base/login/teamModal.vue x: 79 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/AppDashboard.vue x: 76 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StartApplicationModal.vue x: 217 lines of code y: 17 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StatisticCard.vue x: 44 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/flink/app/styles/View.less x: 134 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/views/resource/upload/View.vue x: 220 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/resource/upload/components/UploadDrawer.vue x: 259 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/resource/upload/upload.data.ts x: 55 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/resource/variable/View.vue x: 155 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/resource/variable/components/VariableModal.vue x: 175 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/alarm/components/AlertModal.vue x: 285 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/setting/extlink/components/Modal.vue x: 174 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/setting/system/View.vue x: 153 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/View.vue x: 134 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueModal.vue x: 136 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/index.data.ts x: 43 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/system/member/MemberModal.vue x: 138 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/system/role/components/RoleDrawer.vue x: 192 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/views/system/role/components/RoleInfo.vue x: 115 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/role/role.data.ts x: 84 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/system/token/components/TokenModal.vue x: 70 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/system/token/token.data.ts x: 97 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/system/user/components/UserDrawer.vue x: 80 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/system/user/user.data.ts x: 168 lines of code y: 10 # changes streampark-console/streampark-console-webapp/src/api/resource/upload/index.ts x: 51 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/api/spark/app.ts x: 90 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/api/spark/conf.ts x: 38 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts x: 162 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java x: 119 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Murmur3Hash.java x: 372 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/components/Page/src/PageWrapper.vue x: 172 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/layouts/default/menu/index.vue x: 174 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppResize.vue x: 125 lines of code y: 2 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/SparkVersion.scala x: 79 lines of code y: 5 # changes streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/Spark.scala x: 145 lines of code y: 10 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala x: 92 lines of code y: 17 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnPerJobClient.scala x: 82 lines of code y: 9 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala x: 142 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ResourceController.java x: 71 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationInfoService.java x: 25 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/api/flink/flinkHistory.ts x: 27 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue x: 337 lines of code y: 13 # changes streampark-console/streampark-console-webapp/src/views/resource/upload/components/Upload.vue x: 244 lines of code y: 3 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala x: 110 lines of code y: 11 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/ConfigUtils.scala x: 87 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/RedisClient.scala x: 83 lines of code y: 10 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala x: 227 lines of code y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/SpringContextUtils.java x: 42 lines of code y: 7 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/PackerResourceGC.scala x: 35 lines of code y: 7 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/FlinkDockerfileTemplateTrait.scala x: 58 lines of code y: 6 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala x: 183 lines of code y: 16 # changes streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala x: 146 lines of code y: 22 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/menu.ts x: 36 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/CompareModal.vue x: 131 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSqlCompareModal.vue x: 143 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/spark/app/components/Mergely.vue x: 170 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java x: 38 lines of code y: 12 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigKeys.scala x: 92 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/aspect/AppChangeEventAspect.java x: 36 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/EffectiveTypeEnum.java x: 13 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SparkSqlService.java x: 24 lines of code y: 1 # changes streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SparkSqlValidator.scala x: 62 lines of code y: 1 # changes streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala x: 354 lines of code y: 3 # changes streampark-spark/streampark-spark-sqlclient/src/main/scala/org/apache/streampark/spark/cli/SqlClient.scala x: 37 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java x: 87 lines of code y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/RoleService.java x: 13 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/aspect/OpenAPIAspect.java x: 79 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/OpenAPIComponent.java x: 169 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTFilter.java x: 64 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTToken.java x: 26 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java x: 108 lines of code y: 14 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/ShiroConfig.java x: 72 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java x: 61 lines of code y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java x: 78 lines of code y: 23 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/SsoController.java x: 58 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java x: 111 lines of code y: 29 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/Authenticator.java x: 6 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/UserService.java x: 30 lines of code y: 22 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java x: 81 lines of code y: 26 # changes streampark-console/streampark-console-webapp/src/api/flink/app.ts x: 127 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useSavepoint.tsx x: 123 lines of code y: 5 # changes streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog/JdbcCatalogStoreFactoryOptions.java x: 44 lines of code y: 1 # changes streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog/connections/JdbcConnectionOptions.java x: 105 lines of code y: 1 # changes streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog/connections/SimpleJdbcConnectionProvider.java x: 100 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/store/modules/user.ts x: 202 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/AlertController.java x: 84 lines of code y: 16 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/MemberController.java x: 70 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/AccessTokenMapper.xml x: 50 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/RequestModal/index.tsx x: 84 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/OpenApi/src/index.tsx x: 190 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/design/ant/index.less x: 74 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/IndexController.java x: 13 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/MessageController.java x: 31 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java x: 51 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java x: 47 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/YarnQueueLabelExpression.java x: 75 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/MenuController.java x: 34 lines of code y: 13 # changes streampark-console/streampark-console-webapp/src/api/flink/config.ts x: 41 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/api/resource/variable/index.ts x: 49 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/api/setting/alert.ts x: 34 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/FlinkAppStateEnum.java x: 77 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigOption.scala x: 43 lines of code y: 9 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/AssertUtils.scala x: 95 lines of code y: 5 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/CommandUtils.scala x: 78 lines of code y: 6 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/FileUtils.scala x: 233 lines of code y: 24 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HBaseClient.scala x: 33 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopConfigUtils.scala x: 108 lines of code y: 10 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HostsUtils.scala x: 27 lines of code y: 6 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HttpClientUtils.scala x: 126 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/Implicits.scala x: 55 lines of code y: 1 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/JdbcUtils.scala x: 215 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/MongoConfig.scala x: 137 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/RedisEndpoint.scala x: 146 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/RedisUtils.scala x: 282 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/SqlConvertUtils.scala x: 188 lines of code y: 8 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/ZooKeeperUtils.scala x: 130 lines of code y: 7 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/FailoverChecker.scala x: 30 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/FailoverWriter.scala x: 114 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-base/src/main/scala/org/apache/streampark/flink/connector/failover/SinkBuffer.scala x: 45 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/conf/ClickHouseSinkConfigOption.scala x: 83 lines of code y: 6 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseSinkFunction.scala x: 125 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseSinkWriter.scala x: 63 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseWriterTask.scala x: 103 lines of code y: 7 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/scala/org/apache/streampark/connector/doris/conf/DorisConfig.scala x: 44 lines of code y: 8 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/src/main/scala/org/apache/streampark/flink/connector/elasticsearch5/conf/ESSinkConfigOption.scala x: 41 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/src/main/scala/org/apache/streampark/flink/connector/elasticsearch5/sink/ES5Sink.scala x: 93 lines of code y: 6 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/src/main/scala/org/apache/streampark/flink/connector/elasticsearch6/conf/ES6SinkConfigOption.scala x: 117 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/src/main/scala/org/apache/streampark/flink/connector/elasticsearch7/sink/ES7Sink.scala x: 129 lines of code y: 6 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/internal/HBaseSourceFunction.scala x: 135 lines of code y: 7 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-http/src/main/scala/org/apache/streampark/flink/connector/http/internal/HttpWriterTask.scala x: 130 lines of code y: 6 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-http/src/main/scala/org/apache/streampark/flink/connector/http/sink/HttpSink.scala x: 65 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/src/main/scala/org/apache/streampark/flink/connector/influx/function/InfluxFunction.scala x: 51 lines of code y: 6 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/internal/JdbcSourceFunction.scala x: 112 lines of code y: 8 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/src/main/scala/org/apache/streampark/flink/connector/kafka/source/KafkaSource.scala x: 195 lines of code y: 8 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/sink/RedisSink.scala x: 134 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala x: 144 lines of code y: 9 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/PipelineSnapshot.scala x: 30 lines of code y: 3 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala x: 108 lines of code y: 17 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/conf/FlinkRunOption.scala x: 141 lines of code y: 8 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 108 lines of code y: 5 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/TableContext.scala x: 56 lines of code y: 5 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 112 lines of code y: 4 # changes streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/src/main/scala/org/apache/streampark/spark/connector/kafka/offset/HBaseOffset.scala x: 107 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/ChildFirstClassLoader.scala x: 71 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/SparkAppStateEnum.java x: 53 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java x: 85 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SettingMapper.java x: 8 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebMvcConfig.java x: 60 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/handler/GlobalExceptionHandler.java x: 80 lines of code y: 14 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/interceptor/UploadFileTypeInterceptor.java x: 67 lines of code y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/pager/MybatisPager.java x: 35 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/BashJavaUtils.java x: 105 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/GZipUtils.java x: 73 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Throws.java x: 100 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/Dependency.java x: 69 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/ChangeTypeEnum.java x: 33 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/LoginTypeEnum.java x: 25 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/AlertServiceImpl.java x: 76 lines of code y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/DingTalkAlertNotifyServiceImpl.java x: 137 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/EmailAlertNotifyServiceImpl.java x: 59 lines of code y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/HttpCallbackAlertNotifyServiceImpl.java x: 101 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/LarkAlertNotifyServiceImpl.java x: 119 lines of code y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/WeComAlertNotifyServiceImpl.java x: 77 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java x: 233 lines of code y: 14 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/ShiroService.java x: 61 lines of code y: 5 # changes streampark-flink/streampark-flink-packer/src/main/java/com/github/dockerjava/core/HackDockerClient.java x: 39 lines of code y: 5 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala x: 81 lines of code y: 9 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/K8sFlinkConfig.scala x: 40 lines of code y: 12 # changes streampark-common/src/main/scala/org/apache/streampark/common/fs/LfsOperator.scala x: 113 lines of code y: 6 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/CompletableFutureUtils.scala x: 83 lines of code y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/DateUtils.scala x: 168 lines of code y: 9 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/JsonUtils.scala x: 28 lines of code y: 6 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/Logger.scala x: 110 lines of code y: 10 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/SystemPropertyUtils.scala x: 98 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/interceptor/PostgreSQLQueryInterceptor.java x: 47 lines of code y: 5 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala x: 71 lines of code y: 11 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/LocalClient.scala x: 70 lines of code y: 7 # changes streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/DataStreamExt.scala x: 86 lines of code y: 5 # changes streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/FlinkStreaming.scala x: 55 lines of code y: 9 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/enums/FlinkJobState.scala x: 19 lines of code y: 6 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/K8sPodTemplates.scala x: 38 lines of code y: 6 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/package.scala x: 30 lines of code y: 4 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/PipelineError.scala x: 20 lines of code y: 2 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala x: 136 lines of code y: 12 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala x: 371 lines of code y: 14 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 90 lines of code y: 7 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/TableContext.scala x: 41 lines of code y: 8 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 92 lines of code y: 7 # changes streampark-spark/streampark-spark-connector/streampark-spark-connector-base/src/main/scala/org/apache/streampark/spark/connector/source/Source.scala x: 22 lines of code y: 6 # changes streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/src/main/scala/org/apache/streampark/spark/connector/kafka/offset/MySQLOffset.scala x: 91 lines of code y: 5 # changes streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/src/main/scala/org/apache/streampark/spark/connector/kafka/source/KafkaSource.scala x: 57 lines of code y: 5 # changes streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SQLContextUtil.scala x: 28 lines of code y: 5 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java x: 43 lines of code y: 16 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/Semantic.java x: 17 lines of code y: 7 # changes streampark-common/src/main/java/org/apache/streampark/common/enums/StorageType.java x: 28 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/ResponseCode.java x: 9 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestResponse.java x: 47 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/EncryptUtils.java x: 43 lines of code y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SenderEmail.java x: 38 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ExternalLinkController.java x: 57 lines of code y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/AlertTypeEnum.java x: 64 lines of code y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkSqlMapper.java x: 10 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/AlertConfigService.java x: 12 lines of code y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/TeamController.java x: 53 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MenuMapper.java x: 10 lines of code y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/MemberService.java x: 21 lines of code y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/MenuService.java x: 12 lines of code y: 10 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/DeployResponse.scala x: 2 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/setting/system.ts x: 86 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/State.less x: 104 lines of code y: 5 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/tool/FlinkSessionClientHelper.scala x: 83 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/FormItem.vue x: 360 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/components/Modal/src/components/ModalWrapper.vue x: 148 lines of code y: 9 # changes streampark-console/streampark-console-webapp/src/hooks/setting/useMenuSetting.ts x: 129 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppConf.tsx x: 106 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/FlinkSqlCompareModal.vue x: 148 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx x: 212 lines of code y: 10 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDetail.ts x: 89 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/layout.ts x: 94 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts x: 67 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/setting/alarm.ts x: 72 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/project.ts x: 65 lines of code y: 7 # changes streampark-console/streampark-console-webapp/src/views/setting/system/config.ts x: 119 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/design/public.less x: 49 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/setting/alarm/components/AlertTypeInfo.vue x: 86 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/alarm/components/index.data.ts x: 166 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/system/SettingForm.vue x: 145 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/system/SettingList.vue x: 153 lines of code y: 1 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql x: 272 lines of code y: 5 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql x: 410 lines of code y: 16 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.1.0.sql x: 426 lines of code y: 16 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/bean/DorisSinkBufferEntry.java x: 87 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableColumns.ts x: 80 lines of code y: 2 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkWriter.java x: 290 lines of code y: 6 # changes streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts x: 536 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/resource/project/components/ListItem.vue x: 242 lines of code y: 2 # changes streampark-console/streampark-console-webapp/build/utils.ts x: 67 lines of code y: 2 # changes streampark-console/streampark-console-webapp/build/vite/plugin/compress.ts x: 27 lines of code y: 2 # changes streampark-console/streampark-console-webapp/build/vite/plugin/theme.ts x: 79 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Application/index.ts x: 10 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Basic/src/BasicArrow.vue x: 70 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Container/src/collapse/CollapseContainer.vue x: 100 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/ContextMenu/src/createContextMenu.ts x: 62 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/ContextMenu/src/typing.ts x: 33 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Drawer/src/useDrawer.ts x: 136 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/ApiCascader.vue x: 188 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/ApiRadioGroup.vue x: 116 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/ApiSelect.vue x: 141 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/FormAction.tsx x: 131 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/components/FormAction.vue x: 128 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/hooks/useForm.ts x: 101 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Form/src/hooks/useFormEvents.ts x: 261 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Form/src/props.ts x: 76 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Form/src/types/form.ts x: 147 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Icon/data/icons.data.ts x: 793 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Icon/src/Icon.vue x: 108 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Icon/src/IconPicker.vue x: 168 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Icon/src/SvgIcon.vue x: 61 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Loading/src/Loading.vue x: 76 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Menu/src/props.ts x: 53 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Modal/src/BasicModal.vue x: 218 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Modal/src/hooks/useModal.ts x: 139 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Modal/src/index.less x: 113 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Modal/src/typing.ts x: 72 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Scrollbar/src/Scrollbar.vue x: 186 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/SimpleMenu.vue x: 153 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/components/Menu.vue x: 138 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/components/MenuItem.vue x: 93 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/components/SubMenuItem.vue x: 300 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/components/menu.less x: 257 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/index.less x: 73 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/components/Table/src/components/TableFooter.vue x: 89 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/components/editable/EditableCell.vue x: 451 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Table/src/components/settings/ColumnSetting.vue x: 433 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useColumns.ts x: 269 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useDataSource.ts x: 263 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useRowSelection.ts x: 106 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useTable.ts x: 158 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useTableScroll.ts x: 176 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Table/src/props.ts x: 144 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Transition/src/ExpandTransition.ts x: 65 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Tree/src/BasicTree.vue x: 406 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/components/Tree/src/hooks/useTree.ts x: 178 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/design/ant/btn.less x: 215 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/hooks/web/useContentHeight.ts x: 155 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/hooks/web/useMessage.tsx x: 102 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/hooks/web/useMonaco.ts x: 197 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/Breadcrumb.vue x: 173 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/notify/NoticeList.vue x: 208 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/notify/index.vue x: 185 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/user-dropdown/PasswordModal.vue x: 110 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/components/user-dropdown/index.vue x: 151 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/index.less x: 166 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/header/index.vue x: 193 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/layouts/default/menu/useLayoutMenu.ts x: 83 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/layouts/default/sider/MixSider.vue x: 529 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/layouts/default/tabs/index.less x: 170 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/layouts/default/tabs/index.vue x: 123 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/layouts/page/index.vue x: 56 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/locales/useLocale.ts x: 52 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/router/guard/index.ts x: 113 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/router/helper/menuHelper.ts x: 81 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/store/modules/multipleTab.ts x: 280 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/utils/http/axios/Axios.ts x: 189 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/utils/http/axios/index.ts x: 184 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/base/lock/LockPage.vue x: 212 lines of code y: 2 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/MenuMapper.xml x: 47 lines of code y: 10 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/internal/JdbcSinkFunction.scala x: 93 lines of code y: 4 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/src/main/scala/org/apache/streampark/flink/connector/kafka/sink/KafkaSink.scala x: 72 lines of code y: 5 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/EnhancerImplicit.scala x: 42 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/sink/ClickHouseSink.scala x: 70 lines of code y: 4 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-http/src/main/scala/org/apache/streampark/flink/connector/http/function/HttpSinkFunction.scala x: 65 lines of code y: 4 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/bean/RedisMapper.scala x: 69 lines of code y: 5 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/src/main/java/org/apache/streampark/flink/connector/doris/internal/DorisSinkFunction.java x: 103 lines of code y: 8 # changes streampark-console/streampark-console-webapp/src/api/resource/variable/model/variableModel.ts x: 32 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate/HostAliasDrawer.vue x: 117 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate/PomTemplateTab.vue x: 287 lines of code y: 2 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/State.less x: 39 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/cluster/State.tsx x: 52 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/gateway/View.vue x: 115 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/gateway/components/FlinkGatewayDrawer.vue x: 63 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/resource/project/components/LogModal.vue x: 91 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/Alarm/View.vue x: 283 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/setting/Alarm/components/AlertModal.vue x: 285 lines of code y: 5 # changes streampark-common/src/main/scala/org/apache/streampark/common/fs/FsOperator.scala x: 47 lines of code y: 4 # changes streampark-console/streampark-console-service/src/main/resources/alert-template/alert-email.ftl x: 1155 lines of code y: 7 # changes streampark-console/streampark-console-webapp/index.html x: 150 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/CustomForm.tsx x: 97 lines of code y: 4 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/src/main/scala/org/apache/streampark/flink/connector/elasticsearch5/internal/ESSinkFunction.scala x: 47 lines of code y: 3 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/src/main/scala/org/apache/streampark/flink/connector/influx/sink/InfluxSink.scala x: 35 lines of code y: 3 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/bean/RedisContainer.scala x: 121 lines of code y: 4 # changes streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/internal/Redis2PCSinkFunction.scala x: 57 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/api/system/model/userModel.ts x: 53 lines of code y: 4 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/CompareModal.vue x: 135 lines of code y: 5 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/FlinkSqlDifferent.vue x: 117 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/app/FlinkSqlFormatter.js x: 372 lines of code y: 3 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/Mergely.vue x: 176 lines of code y: 1 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useDiffMonaco.ts x: 96 lines of code y: 1 # changes
67.0
# changes
  min: 1.0
  average: 5.43
  25th percentile: 2.0
  median: 3.0
  75th percentile: 6.0
  max: 67.0
0 1155.0
lines of code
min: 1.0 | average: 79.65 | 25th percentile: 19.0 | median: 46.0 | 75th percentile: 101.0 | max: 1155.0

Number of Contributors vs. Number of Changes: 1503 points

streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala x: 8 # contributors y: 17 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala x: 12 # contributors y: 27 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DistributedTaskServiceImpl.java x: 2 # contributors y: 7 # changes streampark-console/streampark-console-webapp/src/components/Application/src/AppDarkModeToggle.vue x: 3 # contributors y: 9 # changes streampark-console/streampark-console-webapp/src/components/Form/src/BasicForm.vue x: 3 # contributors y: 12 # changes streampark-console/streampark-console-webapp/src/components/Table/src/components/HeaderCell.vue x: 2 # contributors y: 9 # changes streampark-console/streampark-console-webapp/src/router/guard/permissionGuard.ts x: 3 # contributors y: 4 # changes streampark-console/streampark-console-webapp/src/router/routes/basic.ts x: 2 # contributors y: 3 # changes streampark-console/streampark-console-webapp/src/utils/props.ts x: 3 # contributors y: 14 # changes streampark-console/streampark-console-webapp/src/views/setting/alarm/View.vue x: 1 # contributors y: 3 # changes streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql x: 17 # contributors y: 42 # changes streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql x: 16 # contributors y: 39 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql x: 10 # contributors y: 19 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql x: 4 # contributors y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java x: 8 # contributors y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java x: 3 # contributors y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java x: 4 # contributors y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java x: 4 # contributors y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java x: 6 # contributors y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java x: 3 # contributors y: 6 # changes streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql x: 20 # contributors y: 57 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala x: 6 # contributors y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java x: 4 # contributors y: 9 # changes streampark-console/streampark-console-webapp/src/api/system/token.ts x: 2 # contributors y: 4 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala x: 12 # contributors y: 18 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala x: 11 # contributors y: 24 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java x: 5 # contributors y: 18 # changes streampark-console/streampark-console-service/src/main/resources/alert-template/alert-dingTalk.ftl x: 2 # contributors y: 8 # changes streampark-console/streampark-console-webapp/src/settings/siteSetting.ts x: 3 # contributors y: 5 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala x: 13 # contributors y: 42 # changes streampark-console/streampark-console-webapp/src/views/flink/app/Add.vue x: 13 # contributors y: 29 # changes streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue x: 11 # contributors y: 32 # changes streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts x: 5 # contributors y: 14 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts x: 6 # contributors y: 23 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts x: 13 # contributors y: 38 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateSchema.ts x: 8 # contributors y: 18 # changes streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts x: 10 # contributors y: 27 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts x: 12 # contributors y: 44 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts x: 10 # contributors y: 45 # changes streampark-console/streampark-console-webapp/src/views/flink/app/View.vue x: 14 # contributors y: 35 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java x: 5 # contributors y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java x: 6 # contributors y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/ResourceFromEnum.java x: 3 # contributors y: 3 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationConfigServiceImpl.java x: 2 # contributors y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBackupServiceImpl.java x: 1 # contributors y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java x: 5 # contributors y: 20 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/ExecOptionModal.vue x: 1 # contributors y: 2 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala x: 11 # contributors y: 30 # changes streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkYarnApplicationBuildPipeline.scala x: 7 # contributors y: 15 # changes streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql x: 14 # contributors y: 31 # changes streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql x: 13 # contributors y: 28 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/interceptor/PaginationInterceptor.java x: 1 # contributors y: 1 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java x: 6 # contributors y: 11 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkEnvMapper.java x: 6 # contributors y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationConfigMapper.java x: 2 # contributors y: 2 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/VariableMapper.java x: 6 # contributors y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationConfigServiceImpl.java x: 1 # contributors y: 5 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java x: 19 # contributors y: 66 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java x: 17 # contributors y: 31 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSqlServiceImpl.java x: 14 # contributors y: 33 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java x: 23 # contributors y: 67 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java x: 20 # contributors y: 42 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkSqlServiceImpl.java x: 2 # contributors y: 6 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java x: 11 # contributors y: 29 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java x: 10 # contributors y: 22 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java x: 11 # contributors y: 27 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java x: 12 # contributors y: 31 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java x: 17 # contributors y: 52 # changes streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql x: 17 # contributors y: 59 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml x: 6 # contributors y: 14 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ProjectMapper.xml x: 8 # contributors y: 21 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/VariableMapper.xml x: 6 # contributors y: 15 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/YarnQueueMapper.xml x: 4 # contributors y: 11 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml x: 4 # contributors y: 12 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/RoleMapper.xml x: 4 # contributors y: 16 # changes streampark-console/streampark-console-service/src/main/resources/mapper/system/UserMapper.xml x: 7 # contributors y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java x: 5 # contributors y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java x: 13 # contributors y: 18 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java x: 12 # contributors y: 26 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java x: 4 # contributors y: 4 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java x: 7 # contributors y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/LdapService.java x: 7 # contributors y: 9 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java x: 12 # contributors y: 25 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java x: 5 # contributors y: 10 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala x: 4 # contributors y: 10 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java x: 9 # contributors y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java x: 18 # contributors y: 43 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java x: 8 # contributors y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleMenuServiceImpl.java x: 6 # contributors y: 13 # changes streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/PipelineTypeEnum.java x: 5 # contributors y: 6 # changes streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql x: 9 # contributors y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java x: 8 # contributors y: 13 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java x: 3 # contributors y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java x: 26 # contributors y: 62 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java x: 14 # contributors y: 41 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java x: 7 # contributors y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java x: 6 # contributors y: 8 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java x: 4 # contributors y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java x: 5 # contributors y: 7 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java x: 9 # contributors y: 20 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala x: 8 # contributors y: 15 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala x: 5 # contributors y: 11 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkClientTrait.scala x: 7 # contributors y: 8 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue x: 6 # contributors y: 19 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/Workspace.scala x: 9 # contributors y: 16 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ApplicationMapper.java x: 8 # contributors y: 23 # changes streampark-console/streampark-console-service/src/main/resources/mapper/core/ApplicationMapper.xml x: 14 # contributors y: 39 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala x: 5 # contributors y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkSqlController.java x: 11 # contributors y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/VariableController.java x: 7 # contributors y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java x: 10 # contributors y: 21 # changes streampark-console/streampark-console-webapp/src/views/flink/app/data/index.ts x: 4 # contributors y: 14 # changes streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx x: 8 # contributors y: 27 # changes streampark-console/streampark-console-webapp/src/views/spark/app/create.vue x: 3 # contributors y: 11 # changes streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/TriggerSavepointRequest.scala x: 7 # contributors y: 10 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala x: 7 # contributors y: 19 # changes streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/KubernetesNativeClientTrait.scala x: 10 # contributors y: 17 # changes streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala x: 8 # contributors y: 30 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/GitUtils.java x: 8 # contributors y: 16 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ProjectController.java x: 9 # contributors y: 24 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java x: 18 # contributors y: 36 # changes streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkHome.ts x: 6 # contributors y: 7 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala x: 7 # contributors y: 20 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java x: 8 # contributors y: 19 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEnvService.java x: 9 # contributors y: 13 # changes streampark-console/streampark-console-webapp/src/components/Table/src/BasicTable.vue x: 3 # contributors y: 10 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/variable.ts x: 4 # contributors y: 3 # changes streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/setting/flinkHome.ts x: 5 # contributors y: 5 # changes streampark-console/streampark-console-webapp/src/api/system/user.ts x: 5 # contributors y: 13 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StartApplicationModal.vue x: 4 # contributors y: 17 # changes streampark-console/streampark-console-webapp/src/views/resource/upload/components/UploadDrawer.vue x: 1 # contributors y: 6 # changes streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala x: 6 # contributors y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ResourceController.java x: 5 # contributors y: 8 # changes streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue x: 4 # contributors y: 13 # changes streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala x: 8 # contributors y: 22 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java x: 13 # contributors y: 21 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java x: 8 # contributors y: 14 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/ShiroConfig.java x: 5 # contributors y: 15 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java x: 11 # contributors y: 23 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java x: 9 # contributors y: 29 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java x: 10 # contributors y: 26 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/AlertController.java x: 6 # contributors y: 16 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/FileUtils.scala x: 5 # contributors y: 24 # changes streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopConfigUtils.scala x: 2 # contributors y: 10 # changes streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala x: 5 # contributors y: 17 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebMvcConfig.java x: 8 # contributors y: 12 # changes streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/handler/GlobalExceptionHandler.java x: 7 # contributors y: 14 # changes
67.0
# changes
  min: 1.0
  average: 5.43
  25th percentile: 2.0
  median: 3.0
  75th percentile: 6.0
  max: 67.0
0 26.0
# contributors
min: 1.0 | average: 2.99 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 26.0

Number of Contributors vs. File Size: 1503 points

streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala x: 8 # contributors y: 165 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala x: 12 # contributors y: 108 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DistributedTaskServiceImpl.java x: 2 # contributors y: 211 lines of code streampark-console/streampark-console-webapp/src/components/Application/src/AppDarkModeToggle.vue x: 3 # contributors y: 70 lines of code streampark-console/streampark-console-webapp/src/components/ContextMenu/src/ContextMenu.vue x: 3 # contributors y: 186 lines of code streampark-console/streampark-console-webapp/src/components/Form/src/BasicForm.vue x: 3 # contributors y: 319 lines of code streampark-console/streampark-console-webapp/src/components/Page/src/PageFooter.vue x: 3 # contributors y: 49 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/components/HeaderCell.vue x: 2 # contributors y: 44 lines of code streampark-console/streampark-console-webapp/src/hooks/web/useLockPage.ts x: 3 # contributors y: 62 lines of code streampark-console/streampark-console-webapp/src/router/guard/permissionGuard.ts x: 3 # contributors y: 85 lines of code streampark-console/streampark-console-webapp/src/router/routes/basic.ts x: 2 # contributors y: 74 lines of code streampark-console/streampark-console-webapp/src/utils/props.ts x: 3 # contributors y: 141 lines of code streampark-console/streampark-console-webapp/src/views/setting/alarm/View.vue x: 1 # contributors y: 283 lines of code streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql x: 17 # contributors y: 566 lines of code streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql x: 16 # contributors y: 695 lines of code streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql x: 10 # contributors y: 109 lines of code streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.2.sql x: 4 # contributors y: 16 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java x: 8 # contributors y: 26 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationLogServiceImpl.java x: 2 # contributors y: 37 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java x: 3 # contributors y: 784 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java x: 4 # contributors y: 620 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java x: 4 # contributors y: 672 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java x: 6 # contributors y: 461 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java x: 3 # contributors y: 483 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java x: 3 # contributors y: 390 lines of code streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql x: 20 # contributors y: 509 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala x: 6 # contributors y: 101 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java x: 4 # contributors y: 131 lines of code streampark-console/streampark-console-webapp/src/api/system/token.ts x: 2 # contributors y: 25 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala x: 12 # contributors y: 209 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala x: 11 # contributors y: 128 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java x: 5 # contributors y: 17 lines of code streampark-console/streampark-console-service/src/main/resources/alert-template/alert-dingTalk.ftl x: 2 # contributors y: 54 lines of code streampark-console/streampark-console-service/src/main/resources/alert-template/alert-lark.ftl x: 2 # contributors y: 273 lines of code streampark-console/streampark-console-service/src/main/resources/alert-template/alert-weCom.ftl x: 2 # contributors y: 49 lines of code streampark-console/streampark-console-webapp/src/layouts/default/footer/index.vue x: 2 # contributors y: 115 lines of code streampark-console/streampark-console-webapp/src/layouts/default/header/components/Github.vue x: 2 # contributors y: 28 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/sys.ts x: 4 # contributors y: 115 lines of code streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/sys.ts x: 3 # contributors y: 108 lines of code streampark-console/streampark-console-webapp/src/settings/siteSetting.ts x: 3 # contributors y: 5 lines of code streampark-console/streampark-console-webapp/src/utils/http/axios/helper.ts x: 2 # contributors y: 89 lines of code streampark-console/streampark-console-webapp/src/views/base/login/LoginSlogan.tsx x: 3 # contributors y: 76 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala x: 13 # contributors y: 501 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/Add.vue x: 13 # contributors y: 355 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue x: 11 # contributors y: 404 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/FlinkSql.vue x: 3 # contributors y: 275 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts x: 5 # contributors y: 118 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts x: 6 # contributors y: 322 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts x: 13 # contributors y: 613 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateSchema.ts x: 8 # contributors y: 285 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEditStreamPark.ts x: 3 # contributors y: 175 lines of code streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts x: 10 # contributors y: 146 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts x: 12 # contributors y: 321 lines of code streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts x: 10 # contributors y: 309 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/View.vue x: 14 # contributors y: 409 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java x: 5 # contributors y: 46 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java x: 3 # contributors y: 439 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java x: 6 # contributors y: 363 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/ResourceFromEnum.java x: 3 # contributors y: 15 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBackupServiceImpl.java x: 2 # contributors y: 160 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBackupServiceImpl.java x: 1 # contributors y: 161 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java x: 5 # contributors y: 539 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/ExecOptionModal.vue x: 1 # contributors y: 90 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala x: 11 # contributors y: 174 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkYarnApplicationBuildPipeline.scala x: 7 # contributors y: 83 lines of code streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql x: 14 # contributors y: 273 lines of code streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql x: 13 # contributors y: 247 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/MybatisConfig.java x: 6 # contributors y: 64 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/interceptor/PaginationInterceptor.java x: 1 # contributors y: 341 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkApplicationConfigMapper.java x: 1 # contributors y: 8 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkApplicationMapper.java x: 1 # contributors y: 23 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkCatalogMapper.java x: 2 # contributors y: 5 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java x: 6 # contributors y: 5 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ResourceMapper.java x: 4 # contributors y: 9 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProjectService.java x: 7 # contributors y: 32 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationInfoServiceImpl.java x: 1 # contributors y: 416 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationConfigServiceImpl.java x: 1 # contributors y: 222 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkCatalogServiceImpl.java x: 2 # contributors y: 108 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java x: 19 # contributors y: 379 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java x: 17 # contributors y: 133 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSqlServiceImpl.java x: 14 # contributors y: 186 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java x: 23 # contributors y: 419 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java x: 20 # contributors y: 443 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkSqlServiceImpl.java x: 2 # contributors y: 185 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java x: 11 # contributors y: 186 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java x: 10 # contributors y: 190 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/MemberMapper.java x: 4 # contributors y: 12 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java x: 11 # contributors y: 118 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java x: 13 # contributors y: 96 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java x: 12 # contributors y: 112 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java x: 17 # contributors y: 236 lines of code streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql x: 17 # contributors y: 280 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkApplicationConfigMapper.xml x: 1 # contributors y: 17 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkApplicationMapper.xml x: 1 # contributors y: 240 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkCatalogMapper.xml x: 2 # contributors y: 4 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml x: 6 # contributors y: 4 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/ProjectMapper.xml x: 8 # contributors y: 4 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/ResourceMapper.xml x: 3 # contributors y: 29 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationConfigMapper.xml x: 2 # contributors y: 17 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationMapper.xml x: 3 # contributors y: 139 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/VariableMapper.xml x: 6 # contributors y: 29 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/YarnQueueMapper.xml x: 4 # contributors y: 4 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/system/MemberMapper.xml x: 4 # contributors y: 44 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/ServiceHelper.java x: 2 # contributors y: 95 lines of code streampark-flink/streampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCClient.java x: 1 # contributors y: 50 lines of code streampark-flink/streampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCExecutor.java x: 1 # contributors y: 41 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala x: 6 # contributors y: 200 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java x: 5 # contributors y: 252 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java x: 13 # contributors y: 83 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEffectiveServiceImpl.java x: 1 # contributors y: 56 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkEffectiveServiceImpl.java x: 2 # contributors y: 58 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkEnvServiceImpl.java x: 3 # contributors y: 101 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java x: 12 # contributors y: 99 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java x: 7 # contributors y: 38 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java x: 4 # contributors y: 181 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/AlertTemplateUtils.java x: 1 # contributors y: 110 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java x: 12 # contributors y: 655 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java x: 5 # contributors y: 198 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java x: 6 # contributors y: 271 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala x: 4 # contributors y: 174 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationController.java x: 2 # contributors y: 235 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java x: 9 # contributors y: 101 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/WebUtils.java x: 6 # contributors y: 59 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java x: 18 # contributors y: 200 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/RegistryServiceImpl.java x: 2 # contributors y: 164 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java x: 8 # contributors y: 215 lines of code streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/app.ts x: 3 # contributors y: 287 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/PodTemplateTool.scala x: 4 # contributors y: 68 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/SparkK8sPodTemplates.scala x: 1 # contributors y: 34 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/SparkHadoopDockerfileTemplate.scala x: 1 # contributors y: 81 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/BuildRequest.scala x: 7 # contributors y: 107 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkK8sApplicationBuildPipeline.scala x: 1 # contributors y: 190 lines of code streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/SparkClient.scala x: 3 # contributors y: 40 lines of code streampark-console/streampark-console-service/src/main/assembly/conf/config.yaml x: 2 # contributors y: 60 lines of code streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql x: 9 # contributors y: 109 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java x: 8 # contributors y: 59 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java x: 3 # contributors y: 13 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkRobotResponse.java x: 2 # contributors y: 19 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertProbeMsg.java x: 4 # contributors y: 33 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppControl.java x: 2 # contributors y: 13 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/DockerConfig.java x: 3 # contributors y: 32 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/EmailConfig.java x: 3 # contributors y: 41 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/FlinkCatalogParams.java x: 2 # contributors y: 137 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenConfig.java x: 4 # contributors y: 52 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkConfigController.java x: 1 # contributors y: 60 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java x: 4 # contributors y: 210 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java x: 26 # contributors y: 20 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBuildPipeline.java x: 1 # contributors y: 275 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java x: 4 # contributors y: 27 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplicationConfig.java x: 1 # contributors y: 104 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java x: 14 # contributors y: 136 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEffective.java x: 1 # contributors y: 22 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java x: 6 # contributors y: 125 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java x: 7 # contributors y: 88 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Message.java x: 6 # contributors y: 32 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Setting.java x: 4 # contributors y: 28 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationBackup.java x: 1 # contributors y: 53 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkEnv.java x: 3 # contributors y: 97 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java x: 6 # contributors y: 26 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/CheckPoints.java x: 5 # contributors y: 88 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/QuickStartRunner.java x: 2 # contributors y: 66 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java x: 4 # contributors y: 38 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java x: 3 # contributors y: 23 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java x: 4 # contributors y: 22 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java x: 9 # contributors y: 57 lines of code streampark-common/src/main/java/org/apache/streampark/common/enums/CatalogType.java x: 1 # contributors y: 10 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkCatalogBase.java x: 1 # contributors y: 244 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DatabaseServiceImpl.java x: 1 # contributors y: 95 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/TableServiceImpl.java x: 1 # contributors y: 261 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/DataTypeConverterUtils.java x: 1 # contributors y: 148 lines of code streampark-console/streampark-console-service/src/main/resources/config.yaml x: 4 # contributors y: 75 lines of code streampark-flink/streampark-flink-connector-plugin/src/main/java/org/apache/streampark/package-info.java x: 1 # contributors y: 1 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala x: 8 # contributors y: 119 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategy.scala x: 6 # contributors y: 62 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala x: 5 # contributors y: 83 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/K8sDeploymentEventCV.scala x: 3 # contributors y: 4 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkK8sEventWatcher.scala x: 4 # contributors y: 55 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkClientTrait.scala x: 7 # contributors y: 25 lines of code streampark-common/src/main/java/org/apache/streampark/common/enums/SparkJobType.java x: 1 # contributors y: 28 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ProxyController.java x: 2 # contributors y: 97 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java x: 3 # contributors y: 218 lines of code streampark-console/streampark-console-webapp/src/api/spark/app.type.ts x: 2 # contributors y: 119 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/spark/app.ts x: 2 # contributors y: 294 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/spark/home.ts x: 2 # contributors y: 35 lines of code streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts x: 5 # contributors y: 36 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue x: 6 # contributors y: 520 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx x: 5 # contributors y: 361 lines of code streampark-console/streampark-console-webapp/src/views/flink/cluster/View.vue x: 3 # contributors y: 249 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/components/DetailTab.vue x: 3 # contributors y: 449 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/components/State.tsx x: 2 # contributors y: 207 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/detail.vue x: 2 # contributors y: 192 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx x: 2 # contributors y: 379 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts x: 2 # contributors y: 303 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/index.vue x: 2 # contributors y: 393 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkRemoteBuildPipeline.scala x: 5 # contributors y: 65 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkYarnBuildPipeline.scala x: 1 # contributors y: 83 lines of code streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitRequest.scala x: 4 # contributors y: 123 lines of code streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/trait/SparkClientTrait.scala x: 3 # contributors y: 68 lines of code streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/proxy/SparkShimsProxy.scala x: 4 # contributors y: 154 lines of code streampark-common/src/main/scala/org/apache/streampark/common/conf/Workspace.scala x: 9 # contributors y: 68 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationHistoryController.java x: 1 # contributors y: 67 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ApplicationMapper.java x: 8 # contributors y: 5 lines of code streampark-console/streampark-console-service/src/main/resources/mapper/core/ApplicationMapper.xml x: 14 # contributors y: 4 lines of code streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/impl/YarnClient.scala x: 2 # contributors y: 133 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala x: 5 # contributors y: 355 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkSqlController.java x: 11 # contributors y: 96 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/OpenAPIController.java x: 1 # contributors y: 71 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java x: 10 # contributors y: 26 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/VariableService.java x: 7 # contributors y: 19 lines of code streampark-console/streampark-console-webapp/src/api/flink/app.type.ts x: 3 # contributors y: 161 lines of code streampark-console/streampark-console-webapp/src/design/swal2.less x: 3 # contributors y: 90 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkCluster.ts x: 5 # contributors y: 72 lines of code streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/setting/flinkCluster.ts x: 4 # contributors y: 70 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue x: 10 # contributors y: 192 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/EditFlink.vue x: 9 # contributors y: 216 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEdit.ts x: 2 # contributors y: 102 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useEditFlinkSchema.ts x: 3 # contributors y: 110 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx x: 8 # contributors y: 673 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts x: 9 # contributors y: 264 lines of code streampark-console/streampark-console-webapp/src/views/flink/cluster/useClusterSetting.ts x: 2 # contributors y: 382 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/edit.vue x: 2 # contributors y: 159 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useAppFormSchema.tsx x: 2 # contributors y: 282 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/DeployRequest.scala x: 5 # contributors y: 43 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SavepointRequestTrait.scala x: 6 # contributors y: 17 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/TriggerSavepointRequest.scala x: 7 # contributors y: 17 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala x: 7 # contributors y: 170 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/KubernetesNativeClientTrait.scala x: 10 # contributors y: 136 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/DefaultFlinkK8sWatcher.scala x: 5 # contributors y: 113 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/ClusterKey.scala x: 5 # contributors y: 24 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala x: 8 # contributors y: 427 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamTableTrait.scala x: 4 # contributors y: 303 lines of code streampark-console/streampark-console-webapp/src/views/base/login/Login.vue x: 3 # contributors y: 158 lines of code streampark-console/streampark-console-webapp/src/views/base/login/LoginForm.vue x: 10 # contributors y: 200 lines of code streampark-console/streampark-console-webapp/src/views/base/login/LoginSlogan.less x: 3 # contributors y: 239 lines of code streampark-console/streampark-console-webapp/src/components/Drawer/src/BasicDrawer.vue x: 2 # contributors y: 221 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/BuildDrawer.vue x: 3 # contributors y: 212 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSql.vue x: 2 # contributors y: 255 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkRender.tsx x: 2 # contributors y: 264 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/styles/Add.less x: 3 # contributors y: 242 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StopApplicationModal.vue x: 6 # contributors y: 136 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/components/ProgramArgs.vue x: 1 # contributors y: 109 lines of code streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSqlReview.vue x: 1 # contributors y: 38 lines of code streampark-console/streampark-console-webapp/src/views/spark/home/components/Modal.vue x: 2 # contributors y: 153 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/ObjectUtils.java x: 4 # contributors y: 550 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ProjectController.java x: 9 # contributors y: 129 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java x: 18 # contributors y: 216 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java x: 10 # contributors y: 183 lines of code streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue x: 4 # contributors y: 85 lines of code streampark-console/streampark-console-webapp/src/views/flink/home/View.vue x: 2 # contributors y: 181 lines of code streampark-console/streampark-console-webapp/src/views/flink/home/components/Modal.vue x: 4 # contributors y: 165 lines of code streampark-console/streampark-console-webapp/src/views/resource/project/Add.vue x: 1 # contributors y: 74 lines of code streampark-console/streampark-console-webapp/src/views/resource/project/View.vue x: 2 # contributors y: 342 lines of code streampark-console/streampark-console-webapp/src/views/resource/project/useProject.tsx x: 3 # contributors y: 310 lines of code streampark-console/streampark-console-webapp/src/views/system/member/View.vue x: 1 # contributors y: 169 lines of code streampark-console/streampark-console-webapp/src/views/system/team/View.vue x: 1 # contributors y: 131 lines of code streampark-console/streampark-console-webapp/src/views/system/token/View.vue x: 1 # contributors y: 141 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala x: 7 # contributors y: 269 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java x: 8 # contributors y: 88 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java x: 8 # contributors y: 73 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEnvService.java x: 9 # contributors y: 20 lines of code streampark-console/streampark-console-webapp/src/api/flink/flinkCluster.ts x: 2 # contributors y: 70 lines of code streampark-console/streampark-console-webapp/src/api/flink/flinkEnv.ts x: 2 # contributors y: 86 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/BasicTable.vue x: 3 # contributors y: 428 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/types/table.ts x: 2 # contributors y: 227 lines of code streampark-console/streampark-console-webapp/src/design/index.less x: 4 # contributors y: 113 lines of code streampark-console/streampark-console-webapp/src/api/system/user.ts x: 5 # contributors y: 76 lines of code streampark-console/streampark-console-webapp/src/components/Application/src/AppLogo.vue x: 3 # contributors y: 80 lines of code streampark-console/streampark-console-webapp/src/design/var/index.less x: 3 # contributors y: 21 lines of code streampark-console/streampark-console-webapp/src/locales/lang/en/system/user.ts x: 4 # contributors y: 47 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StartApplicationModal.vue x: 4 # contributors y: 217 lines of code streampark-console/streampark-console-webapp/src/views/resource/upload/components/UploadDrawer.vue x: 1 # contributors y: 259 lines of code streampark-console/streampark-console-webapp/src/views/resource/variable/components/VariableModal.vue x: 1 # contributors y: 175 lines of code streampark-console/streampark-console-webapp/src/views/setting/extlink/components/Modal.vue x: 2 # contributors y: 174 lines of code streampark-console/streampark-console-webapp/src/views/setting/system/View.vue x: 1 # contributors y: 153 lines of code streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/YarnQueueModal.vue x: 1 # contributors y: 136 lines of code streampark-console/streampark-console-webapp/src/views/system/member/MemberModal.vue x: 1 # contributors y: 138 lines of code streampark-console/streampark-console-webapp/src/views/system/role/components/RoleDrawer.vue x: 3 # contributors y: 192 lines of code streampark-console/streampark-console-webapp/src/views/system/role/components/RoleInfo.vue x: 3 # contributors y: 115 lines of code streampark-console/streampark-console-webapp/src/views/system/user/components/UserDrawer.vue x: 2 # contributors y: 80 lines of code streampark-console/streampark-console-webapp/src/views/system/user/user.data.ts x: 3 # contributors y: 168 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java x: 5 # contributors y: 119 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Murmur3Hash.java x: 1 # contributors y: 372 lines of code streampark-console/streampark-console-webapp/src/components/Page/src/PageWrapper.vue x: 3 # contributors y: 172 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppResize.vue x: 1 # contributors y: 125 lines of code streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/Spark.scala x: 5 # contributors y: 145 lines of code streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala x: 6 # contributors y: 92 lines of code streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala x: 7 # contributors y: 142 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/Dependency.vue x: 4 # contributors y: 337 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala x: 6 # contributors y: 110 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala x: 8 # contributors y: 227 lines of code streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala x: 9 # contributors y: 183 lines of code streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala x: 8 # contributors y: 146 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java x: 6 # contributors y: 38 lines of code streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigKeys.scala x: 3 # contributors y: 92 lines of code streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala x: 3 # contributors y: 354 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java x: 13 # contributors y: 87 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java x: 5 # contributors y: 10 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/RoleService.java x: 6 # contributors y: 13 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java x: 8 # contributors y: 108 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/PassportController.java x: 11 # contributors y: 78 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/SsoController.java x: 5 # contributors y: 58 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/UserController.java x: 9 # contributors y: 111 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/Authenticator.java x: 5 # contributors y: 6 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/UserService.java x: 8 # contributors y: 30 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java x: 10 # contributors y: 81 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useSavepoint.tsx x: 3 # contributors y: 123 lines of code streampark-flink/streampark-flink-catalog-store/src/main/java/org/apache/streampark/catalog/connections/SimpleJdbcConnectionProvider.java x: 1 # contributors y: 100 lines of code streampark-console/streampark-console-webapp/src/store/modules/user.ts x: 2 # contributors y: 202 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/AlertController.java x: 6 # contributors y: 84 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/MemberController.java x: 8 # contributors y: 70 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java x: 7 # contributors y: 51 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/YarnQueueController.java x: 6 # contributors y: 47 lines of code streampark-common/src/main/scala/org/apache/streampark/common/conf/FlinkVersion.scala x: 6 # contributors y: 118 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/FileUtils.scala x: 5 # contributors y: 233 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/RedisEndpoint.scala x: 2 # contributors y: 146 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/RedisUtils.scala x: 3 # contributors y: 282 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/SqlConvertUtils.scala x: 4 # contributors y: 188 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/ZooKeeperUtils.scala x: 3 # contributors y: 130 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseSinkFunction.scala x: 2 # contributors y: 125 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseWriterTask.scala x: 4 # contributors y: 103 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/internal/HBaseSourceFunction.scala x: 3 # contributors y: 135 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-http/src/main/scala/org/apache/streampark/flink/connector/http/internal/HttpWriterTask.scala x: 2 # contributors y: 130 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/src/main/scala/org/apache/streampark/flink/connector/kafka/source/KafkaSource.scala x: 4 # contributors y: 195 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/conf/RedisSinkConfigOption.scala x: 3 # contributors y: 52 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/sink/RedisSink.scala x: 5 # contributors y: 134 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala x: 4 # contributors y: 144 lines of code streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/PodTemplateParser.scala x: 4 # contributors y: 122 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala x: 5 # contributors y: 108 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/TableContext.scala x: 3 # contributors y: 56 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 2 # contributors y: 112 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/WebMvcConfig.java x: 8 # contributors y: 60 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/handler/GlobalExceptionHandler.java x: 7 # contributors y: 80 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/Dependency.java x: 6 # contributors y: 69 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/AlertServiceImpl.java x: 7 # contributors y: 76 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/DingTalkAlertNotifyServiceImpl.java x: 5 # contributors y: 137 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/HttpCallbackAlertNotifyServiceImpl.java x: 5 # contributors y: 101 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/LarkAlertNotifyServiceImpl.java x: 6 # contributors y: 119 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java x: 8 # contributors y: 233 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/RoleController.java x: 7 # contributors y: 68 lines of code streampark-common/src/main/scala/org/apache/streampark/common/conf/CommonConfig.scala x: 6 # contributors y: 81 lines of code streampark-common/src/main/scala/org/apache/streampark/common/util/SystemPropertyUtils.scala x: 4 # contributors y: 98 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableTrait.scala x: 4 # contributors y: 109 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala x: 8 # contributors y: 371 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 4 # contributors y: 90 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala x: 4 # contributors y: 92 lines of code streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala x: 5 # contributors y: 40 lines of code streampark-common/src/main/java/org/apache/streampark/common/enums/ClusterState.java x: 9 # contributors y: 43 lines of code streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkK8sRestExposedType.java x: 7 # contributors y: 31 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/TeamController.java x: 5 # contributors y: 53 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/MemberService.java x: 6 # contributors y: 21 lines of code streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/MenuService.java x: 7 # contributors y: 12 lines of code streampark-console/streampark-console-webapp/src/components/Form/src/components/FormItem.vue x: 3 # contributors y: 360 lines of code streampark-console/streampark-console-webapp/src/components/Modal/src/components/ModalWrapper.vue x: 3 # contributors y: 148 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx x: 5 # contributors y: 212 lines of code streampark-console/streampark-console-webapp/src/views/setting/alarm/components/index.data.ts x: 1 # contributors y: 166 lines of code streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql x: 3 # contributors y: 272 lines of code streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql x: 8 # contributors y: 410 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/data/option.ts x: 3 # contributors y: 536 lines of code streampark-console/streampark-console-webapp/src/components/Form/src/components/ApiCascader.vue x: 2 # contributors y: 188 lines of code streampark-console/streampark-console-webapp/src/components/Form/src/hooks/useFormEvents.ts x: 3 # contributors y: 261 lines of code streampark-console/streampark-console-webapp/src/components/Icon/data/icons.data.ts x: 2 # contributors y: 793 lines of code streampark-console/streampark-console-webapp/src/components/Modal/src/BasicModal.vue x: 2 # contributors y: 218 lines of code streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/SimpleMenu.vue x: 3 # contributors y: 153 lines of code streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/components/SubMenuItem.vue x: 2 # contributors y: 300 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/components/TableAction.vue x: 3 # contributors y: 181 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/components/editable/EditableCell.vue x: 3 # contributors y: 451 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/components/settings/ColumnSetting.vue x: 2 # contributors y: 433 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/hooks/useColumns.ts x: 2 # contributors y: 269 lines of code streampark-console/streampark-console-webapp/src/components/Table/src/props.ts x: 2 # contributors y: 144 lines of code streampark-console/streampark-console-webapp/src/components/Tree/src/BasicTree.vue x: 2 # contributors y: 406 lines of code streampark-console/streampark-console-webapp/src/hooks/web/useMonaco.ts x: 3 # contributors y: 197 lines of code streampark-console/streampark-console-webapp/src/layouts/default/header/components/notify/NoticeList.vue x: 3 # contributors y: 208 lines of code streampark-console/streampark-console-webapp/src/layouts/default/sider/MixSider.vue x: 2 # contributors y: 529 lines of code streampark-console/streampark-console-webapp/src/layouts/default/tabs/index.less x: 2 # contributors y: 170 lines of code streampark-console/streampark-console-webapp/src/store/modules/multipleTab.ts x: 2 # contributors y: 280 lines of code streampark-console/streampark-console-webapp/src/utils/http/axios/Axios.ts x: 3 # contributors y: 189 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate/HostAliasDrawer.vue x: 1 # contributors y: 117 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/PodTemplate/PomTemplateTab.vue x: 1 # contributors y: 287 lines of code streampark-console/streampark-console-service/src/main/resources/alert-template/alert-email.ftl x: 3 # contributors y: 1155 lines of code streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/src/main/scala/org/apache/streampark/flink/connector/redis/bean/RedisContainer.scala x: 3 # contributors y: 121 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/CompareModal.vue x: 4 # contributors y: 135 lines of code streampark-console/streampark-console-webapp/src/views/flink/app/FlinkSqlFormatter.js x: 2 # contributors y: 372 lines of code
1155.0
lines of code
  min: 1.0
  average: 79.65
  25th percentile: 19.0
  median: 46.0
  75th percentile: 101.0
  max: 1155.0
0 26.0
# contributors
min: 1.0 | average: 2.99 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 26.0