|
Contributor 1 |
Contributor 2 |
# shared files |
1. |
benjobs@apache.org |
460888207@qq.com |
330 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationHistoryController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/AlertController.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ApplicationsFlink116OnYarnWithFlinkSQLTest.java
streampark-console/streampark-console-webapp/src/views/flink/home/components/Modal.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/mapper/RoleMapper.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/ApacheFlinkPage.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
streampark-flink/streampark-flink-packer/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/MybatisConfig.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/applications/ApplicationForm.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertDingTalkParams.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertLarkParams.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/alert/impl/HttpCallbackAlertNotifyServiceImpl.java
.asf.yaml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/YarnQueueMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/GZipUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationManageService.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/ResourceServiceTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Tuple2.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationConfig.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestRequest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/Dependency.java
docker/README.md
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/TeamController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AppBuildDockerResolvedDetail.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/UserManagementPage.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-flink-v1/src/main/java/org/apache/streampark/gateway/flink/FlinkSqlGatewayImpl.java
streampark-e2e/streampark-e2e-core/src/main/java/org/apache/streampark/e2e/core/StreamPark.java
README.md
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Tuple4.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/UserService.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/MemberManagementPage.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationBuildPipelineController.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/TeamManagementTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/Flink116OnYarnClusterDeployTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertProbeMsg.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationBackUpServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Throws.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/YarnSessionForm.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SavePointController.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/ClusterDetailForm.java
docker/Dockerfile
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/flink/Overview.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-flink-v1/src/main/java/org/apache/streampark/gateway/flink/FlinkSqlGatewayServiceFactory.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/MavenPom.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterMeta.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/RoleMenu.java
streampark-console/streampark-console-webapp/src/views/base/login/teamModal.vue
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/alert/AlertServiceTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ApplicationBackUpCleanTask.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/common/NavBarPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/SystemPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/FlinkClustersPage.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/ShiroRealm.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/RoleController.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/system/authentication/JWTTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/FlinkHomeTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/controller/AccessTokenController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/ApplicationActionService.java
streampark-console/streampark-console-service/src/main/resources/mapper/core/SettingMapper.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/VariableController.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/Flink117OnYarnClusterDeployTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/UploadManagementTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/ProjectMapper.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/TokenManagementPage.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/Tuple.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/VariableService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/pager/MybatisPager.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/ShiroConfig.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MenuServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/GitCredentialEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ServiceHelper.java
streampark-e2e/streampark-e2e-case/src/test/resources/docker/flink-1.18-on-yarn/Dockerfile
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/ResourceTypeEnum.java
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/PipelineStepStatusEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/FlinkSQL116OnYarnTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
...
|
2. |
39726513+wangsizhu0504@users.noreply.github.com |
benjobs@apache.org |
81 shared files
streampark-console/streampark-console-webapp/src/views/flink/home/components/Modal.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-console/streampark-console-webapp/src/views/flink/app/Detail.vue
streampark-console/streampark-console-webapp/src/views/flink/app/data/index.ts
streampark-console/streampark-console-webapp/src/api/flink/savepoint.ts
streampark-console/streampark-console-webapp/src/api/system/openapi.ts
streampark-console/streampark-console-webapp/src/views/spark/app/create.vue
streampark-console/streampark-console-webapp/src/views/spark/app/data/detail.data.ts
streampark-console/streampark-console-webapp/src/design/index.less
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkCluster.ts
streampark-console/streampark-console-webapp/src/views/flink/app/EditFlink.vue
streampark-console/streampark-console-webapp/src/views/spark/app/components/SparkSql.vue
streampark-console/streampark-console-webapp/src/components/SimpleMenu/src/SimpleSubMenu.vue
streampark-console/streampark-console-webapp/src/views/flink/home/View.vue
streampark-console/streampark-console-webapp/src/views/spark/app/detail.vue
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts
streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
streampark-console/streampark-console-webapp/src/views/spark/app/edit.vue
streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts
streampark-console/streampark-console-webapp/src/enums/sparkEnum.ts
streampark-console/streampark-console-webapp/src/api/flink/app.type.ts
streampark-console/streampark-console-webapp/src/views/base/login/Login.vue
streampark-console/streampark-console-webapp/src/views/base/login/LoginForm.vue
streampark-console/streampark-console-webapp/src/views/spark/app/components/AppForm.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
streampark-console/streampark-console-webapp/src/layouts/default/sider/LayoutSider.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java
streampark-console/streampark-console-webapp/src/views/spark/home/index.vue
.github/workflows/e2e.yml
streampark-console/streampark-console-webapp/src/views/spark/app/components/State.tsx
streampark-console/streampark-console-webapp/src/views/base/login/LoginSlogan.tsx
streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx
streampark-console/streampark-console-webapp/src/views/spark/app/data/index.ts
streampark-console/streampark-console-webapp/src/components/Table/src/BasicTable.vue
streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useAppFormSchema.tsx
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/setting/flinkCluster.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/spark/home.ts
streampark-console/streampark-console-webapp/src/views/spark/app/components/DetailTab.vue
streampark-console/streampark-console-webapp/src/locales/lang/en/menu.ts
streampark-console/streampark-console-webapp/src/views/flink/app/styles/Add.less
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-webapp/src/views/spark/app/components/BuildDrawer.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/app.ts
streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkClusterMapper.xml
streampark-console/streampark-console-webapp/src/views/spark/home/components/Modal.vue
streampark-console/streampark-console-webapp/src/views/flink/app/View.vue
streampark-console/streampark-console-webapp/src/views/setting/extlink/View.vue
streampark-console/streampark-console-webapp/src/views/spark/app/components/AppDashboard.vue
streampark-console/streampark-console-webapp/src/views/flink/app/components/RequestModal/index.tsx
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-webapp/src/settings/siteSetting.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/variable.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkEnvMapper.java
streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkRender.tsx
streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkHome.ts
streampark-console/streampark-console-webapp/src/views/flink/cluster/Edit.vue
streampark-console/streampark-console-webapp/src/api/resource/upload/index.ts
streampark-console/streampark-console-webapp/src/views/spark/app/index.vue
streampark-console/streampark-console-webapp/src/views/spark/app/components/StatisticCard.vue
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkEnvMapper.xml
streampark-console/streampark-console-webapp/src/views/resource/project/View.vue
streampark-console/streampark-console-webapp/src/api/flink/flinkCluster.ts
streampark-console/streampark-console-webapp/src/views/flink/cluster/View.vue
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/menu.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/spark/app.ts
streampark-console/streampark-console-webapp/src/views/flink/cluster/useClusterSetting.ts
streampark-console/streampark-console-webapp/src/components/Table/src/types/tableAction.ts
streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue
streampark-console/streampark-console-webapp/src/api/spark/app.type.ts
streampark-console/streampark-console-webapp/src/layouts/default/footer/index.vue
streampark-console/streampark-console-webapp/src/views/flink/app/components/AppView/StopApplicationModal.vue
|
3. |
66543456+lenoxzhao@users.noreply.github.com |
benjobs@apache.org |
71 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/SparkOperationEnum.java
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/spark/SparkApplicationSummary.java
streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationMapper.xml
streampark-console/streampark-console-webapp/src/views/spark/app/create.vue
streampark-common/src/main/scala/org/apache/streampark/common/conf/Workspace.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/SparkClient.scala
streampark-console/streampark-console-webapp/src/views/spark/app/data/detail.data.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkProxyController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkYarnApplicationBuildPipeline.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/SparkClientEndpoint.scala
streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkEffectiveMapper.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkEffectiveServiceImpl.java
streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationBackUp.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkAppBuildPipeServiceImpl.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/StopRequest.scala
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/StopResponse.scala
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationBackUpMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProxyService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationActionService.java
streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala
streampark-console/streampark-console-webapp/src/views/spark/app/components/DetailTab.vue
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkSqlMapper.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkConfigController.java
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationInfoService.java
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/app.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/resources/mapper/core/SparkApplicationConfigMapper.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/BuildRequest.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/spark/Job.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkSqlServiceImpl.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/conf/SparkConfiguration.scala
streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/impl/YarnClient.scala
streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/impl/YarnApplicationClient.scala
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/PipelineTypeEnum.java
streampark-common/src/main/java/org/apache/streampark/common/enums/SparkDevelopmentMode.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/SparkAppStateEnum.java
streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/trait/SparkClientTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkEffective.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-spark/streampark-spark-sqlclient/src/main/scala/org/apache/streampark/spark/cli/SqlClient.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/utils/AlertTemplateUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/metrics/spark/SparkExecutor.java
streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/Spark.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/aspect/AppChangeEventAspect.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitRequest.scala
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/proxy/SparkShimsProxy.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationConfigMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-common/src/main/java/org/apache/streampark/common/enums/SparkDeployMode.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitResponse.scala
streampark-common/src/main/scala/org/apache/streampark/common/conf/SparkVersion.scala
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkSql.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationConfig.java
streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala
streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigKeys.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkSqlController.java
|
4. |
benjobs@apache.org |
mr.artboy@gmail.com |
70 shared files
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/helper/KubernetesDeploymentHelper.scala
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
streampark-console/streampark-console-service/src/main/assembly/assembly.xml
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-flink/streampark-flink-kubernetes/pom.xml
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/DatabaseServiceTest.java
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1beta1.scala
streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressController.scala
streampark-console/streampark-console-webapp/package.json
.idea/vcs.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCatalog.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationConfigServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBackupServiceImpl.java
streampark-flink/pom.xml
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts
streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/FlinkCatalogParams.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkCatalogMapper.java
streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkCatalogService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkCatalogController.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/TableServiceTest.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/WebUtils.java
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-flink/streampark-flink-shims/streampark-flink-shims-test/pom.xml
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-console/streampark-console-webapp/src/views/flink/app/Add.vue
streampark-flink/streampark-flink-sqlclient/pom.xml
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-flink/streampark-flink-core/pom.xml
streampark-console/streampark-console-webapp/src/views/flink/app/View.vue
streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkJobType.java
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategy.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/util/ServiceHelper.java
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkCatalogServiceImpl.java
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkK8sEventWatcher.scala
streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/pom.xml
tools/dependencies/known-dependencies.txt
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkClientTrait.scala
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateSchema.ts
pom.xml
streampark-console/streampark-console-service/pom.xml
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlValidator.scala
streampark-console/streampark-console-webapp/src/views/flink/app/components/FlinkSql.vue
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
streampark-console/streampark-console-service/src/main/resources/mapper/core/FlinkCatalogMapper.xml
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkYarnApplicationBuildPipeline.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
5. |
benjobs@apache.org |
65238551+hxpserein@users.noreply.github.com |
67 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/DistributedTaskService.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/docker/FlinkDockerfileTemplateTrait.scala
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
streampark-console/streampark-console-registry/streampark-registry-api/src/main/java/org/apache/streampark/registry/api/ConnectStrategyProperties.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java
streampark-console/streampark-console-registry/streampark-registry-api/src/main/java/org/apache/streampark/registry/api/model/Server.java
streampark-common/src/main/scala/org/apache/streampark/common/util/ConfigUtils.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-registry/streampark-registry-api/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/config/ConsoleConfig.java
streampark-console/streampark-console-registry/streampark-registry-plugins/streampark-registry-jdbc/src/main/java/org/apache/streampark/plugin/registry/jdbc/JdbcRegistry.java
streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala
streampark-console/streampark-console-registry/streampark-registry-plugins/streampark-registry-it/src/test/java/org/apache/streampark/plugin/registry/RegistryTestCase.java
streampark-console/streampark-console-service/src/main/assembly/conf/config.yaml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SavepointRequestTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/DistributedTaskEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkAppBuildPipeServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/RegistryServiceImpl.java
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/CancelRequest.scala
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/SpringUnitTestBase.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/SpringContextUtils.java
streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java
streampark-common/src/main/scala/org/apache/streampark/common/util/RedisClient.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/DistributedTask.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/DistributedTaskServiceTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/DistributedTaskServiceImpl.java
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
streampark-console/streampark-console-registry/pom.xml
tools/dependencies/known-dependencies.txt
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/FlinkTaskItem.java
pom.xml
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/TriggerSavepointRequest.scala
streampark-common/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/SparkTaskItem.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/pom.xml
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitRequest.scala
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/PackerResourceGC.scala
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/proxy/SparkShimsProxy.scala
streampark-console/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/SqlGatewayServiceFactoryUtils.java
streampark-console/streampark-console-registry/streampark-registry-api/src/main/java/org/apache/streampark/registry/api/model/BaseHeartBeat.java
|
6. |
benjobs@apache.org |
madzhou1@gmail.com |
48 shared files
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/AlertTypeDetailForm.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/MemberManagementPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/ClusterDetailForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/YarnQueuePage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/common/NavBarPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/SystemPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/CommonForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/UploadManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/TokenManagementPage.java
streampark-console/streampark-console-webapp/src/views/system/role/role.data.ts
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/EnvironmentPage.java
.github/workflows/e2e.yml
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/YarnQueueTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/CommonForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/LarkAlertForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/SettingPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/UploadsPage.java
streampark-console/streampark-console-webapp/src/views/system/role/components/RoleDrawer.vue
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/RoleManagementPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/SMSAlertForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/MavenSettingForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/resource/VariableManagementTest.java
streampark-console/streampark-console-webapp/src/views/system/role/components/RoleInfo.vue
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/EmailSettingForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/AlarmPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/DockerSettingForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/RemoteForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/RoleManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/ResourcePage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/Flink117OnRemoteClusterDeployTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/VariableManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/IngressSettingForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/VariablesPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/Flink118OnRemoteClusterDeployTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/ExternalLinkTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/DingTalkAlertForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/WeChatAlertForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/MemberManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/EnvironmentTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/TokenManagementTest.java
streampark-console/streampark-console-webapp/src/views/resource/upload/View.vue
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/Flink116OnRemoteClusterDeployTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/env/EnvironmentDetailForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/ExternalLinkPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/AlarmTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/setting/alarm/EmailAlertForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/VariableManagementPage.java
|
7. |
benjobs@apache.org |
37063904+zhuangchong@users.noreply.github.com |
35 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/View.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/entity/BaseEntity.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-webapp/src/settings/siteSetting.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java
pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java
streampark-console/streampark-console-webapp/src/views/setting/yarn-queue/index.data.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
streampark-console/streampark-console-webapp/src/views/resource/variable/View.vue
|
8. |
460888207@qq.com |
65238551+hxpserein@users.noreply.github.com |
29 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/base/util/EncryptUtilsTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkAppBuildPipeServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/SpringUnitTestBase.java
streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/base/util/ShaHashUtilsTest.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/SpringContextUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java
tools/dependencies/known-dependencies.txt
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/pom.xml
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/SqlGatewayServiceFactoryUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java
|
9. |
460888207@qq.com |
37063904+zhuangchong@users.noreply.github.com |
28 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/YarnQueue.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkGateWay.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AlertConfig.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/MemberServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Role.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/TeamServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/AccessToken.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ExternalLink.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/AccessTokenServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Menu.java
pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Team.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/Member.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/router/RouterTree.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
10. |
leisure2001@163.com |
benjobs@apache.org |
19 shared files
streampark-console/streampark-console-webapp/src/locales/lang/en/system/member.ts
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkCluster.ts
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-webapp/src/locales/lang/en/system/team.ts
streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/resource.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-console/streampark-console-webapp/src/views/resource/project/useProject.tsx
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkHome.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala
|
11. |
benjobs@apache.org |
349382581@qq.com |
19 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Savepoint.java
streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProxyService.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala
streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java
streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ProxyController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationLogServiceImpl.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnPerJobClient.scala
streampark-console/streampark-console-webapp/src/views/flink/cluster/View.vue
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
|
12. |
460888207@qq.com |
madzhou1@gmail.com |
19 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/MemberManagementPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/flink/clusters/ClusterDetailForm.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/common/CommonFactory.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/common/NavBarPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/SystemPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/UploadManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/TokenManagementPage.java
.github/workflows/e2e.yml
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/UploadsPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/system/RoleManagementPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/resource/VariableManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/RoleManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/ResourcePage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/VariableManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/VariablesPage.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/MemberManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/cases/TokenManagementTest.java
streampark-e2e/streampark-e2e-case/src/test/java/org/apache/streampark/e2e/pages/resource/VariableManagementPage.java
|
13. |
460888207@qq.com |
66543456+lenoxzhao@users.noreply.github.com |
18 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkAppBuildPipeServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationActionService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/EffectiveTypeEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationInfoService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/java/org/apache/streampark/flink/packer/pipeline/PipelineTypeEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/SparkAppStateEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/utils/AlertTemplateUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java
|
14. |
460888207@qq.com |
gongzhongqiang@apache.org |
17 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSqlServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkSqlController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEnvService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java
streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/RestResponse.java
|
15. |
65238551+hxpserein@users.noreply.github.com |
mr.artboy@gmail.com |
17 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java
streampark-console/streampark-console-service/src/main/resources/config.yaml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/pgsql/2.2.0.sql
streampark-console/streampark-console-service/src/test/resources/application-test.yml
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-common/src/main/java/org/apache/streampark/common/constants/Constants.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
tools/dependencies/known-dependencies.txt
pom.xml
streampark-console/streampark-console-service/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
16. |
benjobs@apache.org |
gongzhongqiang@apache.org |
15 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/VariableServiceImpl.java
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSqlServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkSqlController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationBuildPipelineController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java
streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue
|
17. |
benjobs@apache.org |
48339061+aalron@users.noreply.github.com |
13 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationLogServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
18. |
460888207@qq.com |
39726513+wangsizhu0504@users.noreply.github.com |
13 shared files
streampark-console/streampark-console-webapp/src/views/flink/home/components/Modal.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-console/streampark-console-webapp/src/views/base/login/LoginForm.vue
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java
.github/workflows/e2e.yml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkClusterMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/FlinkEnvMapper.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEnvService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue
|
19. |
66543456+lenoxzhao@users.noreply.github.com |
65238551+hxpserein@users.noreply.github.com |
12 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkAppBuildPipeServiceImpl.java
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/bean/SubmitRequest.scala
streampark-spark/streampark-spark-client/streampark-spark-client-api/src/main/scala/org/apache/streampark/spark/client/proxy/SparkShimsProxy.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java
|
20. |
460888207@qq.com |
mr.artboy@gmail.com |
10 shared files
streampark-flink/streampark-flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/CompatibleKubernetesWatcher.java
streampark-flink/streampark-flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/CompKubernetesDeployment.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/JacksonUtils.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/util/WebUtils.java
tools/dependencies/known-dependencies.txt
pom.xml
streampark-console/streampark-console-service/pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
21. |
77189278+caicancai@users.noreply.github.com |
benjobs@apache.org |
9 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/handler/GlobalExceptionHandler.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
22. |
460888207@qq.com |
70357858+forus0322@users.noreply.github.com |
8 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/LdapService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
23. |
460888207@qq.com |
whushawhe@163.com |
8 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/PlaceholderTypeEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/RoleService.java
|
24. |
benjobs@apache.org |
70357858+forus0322@users.noreply.github.com |
8 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkK8sChangeEventListener.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
25. |
mr.artboy@gmail.com |
48339061+aalron@users.noreply.github.com |
8 shared files
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkSavepointServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
26. |
77189278+caicancai@users.noreply.github.com |
460888207@qq.com |
8 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/handler/GlobalExceptionHandler.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkCluster.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
27. |
39726513+wangsizhu0504@users.noreply.github.com |
mr.artboy@gmail.com |
8 shared files
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts
streampark-console/streampark-console-webapp/src/views/flink/app/EditStreamPark.vue
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useCreateAndEditSchema.ts
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-webapp/src/views/flink/app/View.vue
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
streampark-console/streampark-console-webapp/src/enums/flinkEnum.ts
|
28. |
349382581@qq.com |
460888207@qq.com |
7 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationBackUp.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkSql.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ApplicationLogService.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationLogServiceImpl.java
|
29. |
benjobs@apache.org |
whushawhe@163.com |
7 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/domain/Constant.java
streampark-console/streampark-console-webapp/src/views/setting/extlink/components/Modal.vue
|
30. |
37063904+zhuangchong@users.noreply.github.com |
65238551+hxpserein@users.noreply.github.com |
7 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Variable.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
pom.xml
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
31. |
65238551+hxpserein@users.noreply.github.com |
48339061+aalron@users.noreply.github.com |
6 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
32. |
leisure2001@163.com |
mr.artboy@gmail.com |
6 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
33. |
66543456+lenoxzhao@users.noreply.github.com |
mr.artboy@gmail.com |
6 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
34. |
37063904+zhuangchong@users.noreply.github.com |
66543456+lenoxzhao@users.noreply.github.com |
5 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
|
35. |
65238551+hxpserein@users.noreply.github.com |
gongzhongqiang@apache.org |
5 shared files
streampark-flink/streampark-flink-sql-gateway/streampark-flink-sql-gateway-base/src/main/java/org/apache/streampark/gateway/factories/FactoryUtil.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
|
36. |
37063904+zhuangchong@users.noreply.github.com |
whushawhe@163.com |
5 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/RoleServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/security/impl/AuthenticatorImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/service/impl/UserServiceImpl.java
|
37. |
39726513+wangsizhu0504@users.noreply.github.com |
66543456+lenoxzhao@users.noreply.github.com |
5 shared files
streampark-console/streampark-console-webapp/src/views/spark/app/create.vue
streampark-console/streampark-console-webapp/src/views/spark/app/data/detail.data.ts
streampark-console/streampark-console-webapp/src/views/spark/app/components/DetailTab.vue
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/spark/app.ts
|
38. |
leisure2001@163.com |
66543456+lenoxzhao@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
39. |
36791902+zzzk1@users.noreply.github.com |
66543456+lenoxzhao@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/AsyncExecutorPoolConfig.java
|
40. |
37063904+zhuangchong@users.noreply.github.com |
mr.artboy@gmail.com |
4 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
pom.xml
|
41. |
leisure2001@163.com |
460888207@qq.com |
4 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useFlinkRender.tsx
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
|
42. |
leisure2001@163.com |
39726513+wangsizhu0504@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkCluster.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
streampark-console/streampark-console-webapp/src/locales/lang/en/setting/flinkHome.ts
|
43. |
349382581@qq.com |
66543456+lenoxzhao@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/ProxyService.java
streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
|
44. |
37063904+zhuangchong@users.noreply.github.com |
39726513+wangsizhu0504@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-webapp/src/settings/siteSetting.ts
|
45. |
66543456+lenoxzhao@users.noreply.github.com |
48339061+aalron@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/resources/db/schema-h2.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
46. |
gongzhongqiang@apache.org |
39726513+wangsizhu0504@users.noreply.github.com |
4 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkEnvController.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkEnvService.java
streampark-console/streampark-console-webapp/src/views/flink/cluster/Add.vue
|
47. |
460888207@qq.com |
48339061+aalron@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/SpringProperties.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java
|
48. |
benjobs@apache.org |
36791902+zzzk1@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
|
49. |
36791902+zzzk1@users.noreply.github.com |
37063904+zhuangchong@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
|
50. |
36791902+zzzk1@users.noreply.github.com |
mr.artboy@gmail.com |
3 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
|
51. |
460888207@qq.com |
1900022824@pku.edu.cn |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/NoticeTypeEnum.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
|
52. |
benjobs@apache.org |
33508807+dyccode@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
|
53. |
33508807+dyccode@users.noreply.github.com |
65238551+hxpserein@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
|
54. |
mr.artboy@gmail.com |
70357858+forus0322@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkClusterWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
55. |
leisure2001@163.com |
65238551+hxpserein@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
56. |
39726513+wangsizhu0504@users.noreply.github.com |
349382581@qq.com |
3 shared files
streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts
streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
streampark-console/streampark-console-webapp/src/views/flink/cluster/View.vue
|
57. |
65238551+hxpserein@users.noreply.github.com |
349382581@qq.com |
3 shared files
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/runner/EnvInitializer.java
|
58. |
leisure2001@163.com |
77189278+caicancai@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
|
59. |
77189278+caicancai@users.noreply.github.com |
gongzhongqiang@apache.org |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SqlCompleteServiceImpl.java
|
60. |
77189278+caicancai@users.noreply.github.com |
65238551+hxpserein@users.noreply.github.com |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
61. |
37063904+zhuangchong@users.noreply.github.com |
gongzhongqiang@apache.org |
3 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
|
62. |
105206850+xieyi888@users.noreply.github.com |
benjobs@apache.org |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
|
63. |
leisure2001@163.com |
36791902+zzzk1@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
|
64. |
leisure2001@163.com |
37063904+zhuangchong@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
streampark-console/streampark-console-service/src/main/assembly/script/data/pgsql-data.sql
|
65. |
66543456+lenoxzhao@users.noreply.github.com |
70357858+forus0322@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/AlertTemplate.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
66. |
460888207@qq.com |
33508807+dyccode@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationInfoServiceImpl.java
|
67. |
33508807+dyccode@users.noreply.github.com |
mr.artboy@gmail.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
|
68. |
65238551+hxpserein@users.noreply.github.com |
70357858+forus0322@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java
|
69. |
leisure2001@163.com |
48339061+aalron@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql
streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
|
70. |
benjobs@apache.org |
zhilinli0706@gmail.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
|
71. |
mr.artboy@gmail.com |
zhilinli0706@gmail.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts
|
72. |
349382581@qq.com |
mr.artboy@gmail.com |
2 shared files
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnSessionClient.scala
|
73. |
benjobs@apache.org |
duanfangwei2012@sina.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
|
74. |
benjobs@apache.org |
1900022824@pku.edu.cn |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/MessageServiceImpl.java
|
75. |
460888207@qq.com |
duanfangwei2012@sina.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
|
76. |
77189278+caicancai@users.noreply.github.com |
37063904+zhuangchong@users.noreply.github.com |
2 shared files
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProjectServiceImpl.java
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
|
77. |
benjobs@apache.org |
595209256@qq.com |
1 shared file
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
|
78. |
mr.artboy@gmail.com |
595209256@qq.com |
1 shared file
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/ingress/IngressStrategyV1.scala
|
79. |
105206850+xieyi888@users.noreply.github.com |
460888207@qq.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
|
80. |
349382581@qq.com |
gongzhongqiang@apache.org |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
|
81. |
460888207@qq.com |
zhilinli0706@gmail.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java
|
82. |
madzhou1@gmail.com |
37063904+zhuangchong@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
|
83. |
madzhou1@gmail.com |
whushawhe@163.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ExternalLinkServiceImpl.java
|
84. |
33508807+dyccode@users.noreply.github.com |
70357858+forus0322@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java
|
85. |
105206850+xieyi888@users.noreply.github.com |
mr.artboy@gmail.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
|
86. |
105206850+xieyi888@users.noreply.github.com |
48339061+aalron@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
|
87. |
349382581@qq.com |
48339061+aalron@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/ApplicationLog.java
|
88. |
zhilinli0706@gmail.com |
48339061+aalron@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
|
89. |
39726513+wangsizhu0504@users.noreply.github.com |
madzhou1@gmail.com |
1 shared file
.github/workflows/e2e.yml
|
90. |
whushawhe@163.com |
65238551+hxpserein@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/entity/User.java
|
91. |
benjobs@apache.org |
149778446+joycurry30@users.noreply.github.com |
1 shared file
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
|
92. |
149778446+joycurry30@users.noreply.github.com |
65238551+hxpserein@users.noreply.github.com |
1 shared file
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
|
93. |
149778446+joycurry30@users.noreply.github.com |
349382581@qq.com |
1 shared file
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
|
94. |
149778446+joycurry30@users.noreply.github.com |
mr.artboy@gmail.com |
1 shared file
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/YarnApplicationClient.scala
|
95. |
benjobs@apache.org |
2827528315@qq.com |
1 shared file
streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala
|
96. |
36791902+zzzk1@users.noreply.github.com |
39726513+wangsizhu0504@users.noreply.github.com |
1 shared file
streampark-console/streampark-console-service/src/main/resources/db/data-h2.sql
|
97. |
leisure2001@163.com |
gongzhongqiang@apache.org |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
|
98. |
leisure2001@163.com |
duanfangwei2012@sina.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
|
99. |
leisure2001@163.com |
1900022824@pku.edu.cn |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
|
100. |
77189278+caicancai@users.noreply.github.com |
duanfangwei2012@sina.com |
1 shared file
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
|