github.com/apache/incubator-streampark commits

[ISSUE-3064][Improve] Improve streampark-console core package module service name base on [3.1 Naming Style] (#3295)

57b9b78dd4f230ee6403fa9a45ded7695042f04f authored about 1 year ago by VampireAchao <[email protected]>

[Bug] extract program arguments bug fixed. (#3297)

* [Improve] packageArgs improvement

* minor improvement

* [Improve] minor improve

* [Im...

4dc5eb7eaf91382d0fcf7001c27cffb65bf0d95d authored about 1 year ago by benjobs <[email protected]>

[ISSUE-3299][Improve] Improve streampark-flink-client module base on [3.1 Naming Style] (#3300)

ba269cbbf0eb5655efced43dc00fd6a2aac65327 authored about 1 year ago by caicancai <[email protected]>

[improve] Change first letter case (#3296)

f83210f48b7c47b8b665061ae2b2e0886781f298 authored about 1 year ago by caicancai <[email protected]>

fix(grammatical): Spelling mistakes (#3293)

b58022c100e88e4dc45efc379c7ce2ef1da56f80 authored about 1 year ago by Abhinesh <[email protected]>

[Improve] Improve streampark-console system package module mapper name base on [3.1 Naming Style] (#3292)

ecd3d79198eb8bfc0b1ec7296ac70d9d8cc4a043 authored about 1 year ago by VampireAchao <[email protected]>

[Improve] Update the 'streampark.yarn.http-auth' configuration from 'sample' to 'simple' (#3289)

85b7958825b8e63956a1e85a0daa5df25ca44249 authored about 1 year ago by 阿甘兄 <[email protected]>

[WIP][Feature] Support Flink 1.18 application submit (#3169)

* [Feature] Support Flink 1.18 application submit

* Adaptive Flink1.18

* Optimized code

...

6ea643967457899b3020307ccbe0b4c36f2aa1dd authored about 1 year ago by ChengJie1053 <[email protected]>

[Fix] SqlDialect `DEFAULT` requires capitalization (#3277)

* [Fix] sqlDialect "DEFAULT" requires capitalization

47f50ee2ba1e0458953210fd5e45e93b789766d6 authored about 1 year ago by ChengJie1053 <[email protected]>

[ISSUE-3064][Improve] Improve streampark-console core package module mapper name base on [3.1 Naming Style] (#3261)

* [Improve] Improve streampark-console core package module mapper name base on [3.1 Naming Style]

a8abc4abcef0507656f74240213200d15032b0d2 authored about 1 year ago by VampireAchao <[email protected]>

[Hotfix] Translate pyflink.md (#3273)

c1f52ed0a1d9ee5e376697ccaaafe4d67326731f authored about 1 year ago by VampireAchao <[email protected]>

[Improve] Constant improvement (#3272)

* [Improve] Constant improvement

* minor imprement

---------

Co-authored-by: benjobs <b...

a35618b2479936ef6915f201f959b5275bc3e19c authored about 1 year ago by benjobs <[email protected]>

[ISSUE-3083][Improve] Improve streampark-flink module base on [3.2 Constant Variables Definition] (#3264)

db330bb258a08459a04b6c93754c6af75a1c0ac0 authored about 1 year ago by Yuepeng Pan <[email protected]>

[ISSUE-3061][Improve] Improve streampark-common module base on [4 Exception Processing] (#3266)

4fab3671553b3409aa68940d879cbda5efa494d3 authored about 1 year ago by Yuepeng Pan <[email protected]>

[Improve][All] Improvement of deprecated annotation (#3267)

676eb13e35d7b3820cdac09b1a0bf2e1a6a72b0b authored about 1 year ago by ChunFuWu <[email protected]>

[Hotfix] Fix the codestyle (#3270)

bf6b66c94b63fe76ab79693d02c9ea04e7939685 authored about 1 year ago by Yuepeng Pan <[email protected]>

[hotfix] Remove unnecessary management endpoints configuration (#3269)

4c932d39b44f48a8da42bbe8d1a1fb16949902e2 authored about 1 year ago by gongzhongqiang <[email protected]>

[Hotfix] Add interface document and polish code (#3268)

392613280ed996aa1783f8033f720e388d7e3ad3 authored about 1 year ago by gongzhongqiang <[email protected]>

use https://rules.sonarsource.com/java/RSPEC-2696/ Update SpringContextUtils.java (#3259)

see https://rules.sonarsource.com/java/RSPEC-2696/

2b2b392bd94f323b6700272db480c27ff85c61ea authored about 1 year ago by VampireAchao <[email protected]>

[ISSUE-3062][Improve] Improve streampark-common module base on [5 Log] (#3265)

ed8d3ead4c6bee4b42c176416b11da72aad79f53 authored about 1 year ago by Yuepeng Pan <[email protected]>

[Improve] Improve streampark-common module base on https://rules.sonarsource.com/java/RSPEC-3457/ (#3258)

81c2bc9c40ec0c7ea604a7252a2716ff704252e0 authored about 1 year ago by VampireAchao <[email protected]>

[Improve] [Flink-Kubernetes-V2] Add test examples for watching restSvcEndpointSnaps (#3257)

e5bf407fd281cc246b965660ac8073c6a8730faf authored about 1 year ago by caicancai <[email protected]>

[Improve]Modify the comment (#3253)

* [Improve] Modify the comment

1093eaa48264262b8e5b4857cdda219079bff797 authored about 1 year ago by caicancai <[email protected]>

[ISSUE-3065][Improve] Improve streampark-console module base on [3.2 Constant Variables Definition] #3065 (#3251)

* [ISSUE-3075][Improve] Improve streampark-console module base on [5 Log] #3075
* Improve stre...

e338d0a41be0456b5d0630086991e57dc8c78410 authored about 1 year ago by jaslou <[email protected]>

[Improve][Doc] Improve README.md (#3249)

* [Improve] Improve README.md

50a98c008f2da58ca13aa5e3282aa0d534ebddf3 authored about 1 year ago by caicancai <[email protected]>

[Improve] Refactor the menus (#3225)

* [WIP][Improve] reorganize the menus

* icon style improvement

* menu icon style improveme...

60724913f82903c790e1efbf09a9c6f18e1fbbac authored about 1 year ago by benjobs <[email protected]>

[Improve] change serviceaccount (#3241)

5879aec285b31bdee986fe37a030f5098a040188 authored about 1 year ago by caicancai <[email protected]>

[Fix-3226] If the user does not have any more attributes, they will not be able to log in. (#3237)

* fix issue 3226

* fix spotless error

f37372feb2cd113c40be7db664479524049b2fc8 authored about 1 year ago by xiangzihao <[email protected]>

[Feature] Optimize the return value of the shutdown interface (#3239)

40e8e8359567ba7ecb6699320ea93aa09c695e75 authored about 1 year ago by caicancai <[email protected]>

[Improve] Change describing ambiguous logs and printing logs (#3235)

e33e185a74073ee6a5a84fe374738d9d8deec624 authored about 1 year ago by caicancai <[email protected]>

[Fix-3153] Alert information cannot be sent in cancelling state (#3157)

* fix issue 3153

* optimize alert logic

* fix spotless check

bd2f754c4c0f80d03741a71761cb2159a0080ebf authored about 1 year ago by xiangzihao <[email protected]>

[ISSUE-3109][Improve] Improve streampark-testcontainer module based on [3.2 Constant Variables Definition] (#3234)

* [ISSUE-3109][Improve] Improve streampark-testcontainer module based on [3.2 Constant Variables...

762923a4106c6e485f0f6277baa501e43d7f15f9 authored about 1 year ago by Yuepeng Pan <[email protected]>

[ISSUE-3114][Improve] Improve streampark-testcontainer module based on [3.7 Code Comments Rule] (#3233)

daf9cfd0cf15728ecb72295ca570cc82487fce86 authored about 1 year ago by Yuepeng Pan <[email protected]>

[ISSUE-3110][Improve] Improve streampark-testcontainer module based on [3.3 Methods Rule] (#3232)

b6486807b8edf5a4412f7fbb2dc6ff1e849516f3 authored about 1 year ago by Yuepeng Pan <[email protected]>

[Improve] Improve streampark-flink-client-core module base on Naming Style and add log (#3231)

b7eacf8ee9332e18d9558599d411aeb3c34130e0 authored about 1 year ago by caicancai <[email protected]>

[ISSUE-3075][Improve] Improve streampark-console module base on [5 Log] #3075 (#3229)

Co-authored-by: jaslou <jaslouxzhlqq.com>

1f35c808cd71a18b5c5f68a25a3a41acd29692bd authored about 1 year ago by jaslou <[email protected]>

[Improve] Improve streampark-flink-client-core module base on [Naming Style] (#3228)

babb4948287774de4b891716e3c7d35eedf6db26 authored about 1 year ago by caicancai <[email protected]>

[ISSUE-3108][Improve] Improve streampark-testcontainer module based on [3.1 Naming Style] (#3227)

c1fe5715b02f79bd1ca077e8e95e101ce437785a authored about 1 year ago by Yuepeng Pan <[email protected]>

[Feature] [Flink-K8s-V2] Refactor the lifecycle control code of Flink clusters on Kubernetes (#3224)

095be65b7ac9ee7c71c4813fbbf0b2fc7b6be422 authored about 1 year ago by caicancai <[email protected]>

[Improve] Flink cluster executionMode improvement (#3223)

2c488801586e65f85eee97d3d393e49aeb17945c authored about 1 year ago by benjobs <[email protected]>

[Feature][Flink-K8s-V2] Add KubernetesApplicationClient.shutdown on Flink-Kubernetes-V2 (#3186)

* [Feature] Add Kubernetes native application client.shutdown on Flink-Kubernetes-V2

* mvn sp...

6fcf868dd3ea90c97b08eee31004e65cd998e4a0 authored about 1 year ago by caicancai <[email protected]>

[Improve] [Flink-Kubernetes-V2] add observer untrack on Flink-Kubernetes-V2-Session (#3216)

* improve README.md

* [Improve]improve README.md

* [Bug][Flink-Kubernetes-V2] observer.unt...

373ec18aad3ddd4d79d0ebf55038cefe19b73cb3 authored about 1 year ago by caicancai <[email protected]>

[Feature] Add a userId field to ApplicationLog to record the operator (#3221)

Co-authored-by: gongzhongqiang <[email protected]>

1cb57d677622dd2bfc1ab25071ff9bb2c829b94d authored about 1 year ago by gongzhongqiang <[email protected]>

improve streampark-console module base on [3.4 Collection Rule] (#3219)

Co-authored-by: lihui <[email protected]>

09e0882eb3c37444d935af29fb3abb775c26465e authored about 1 year ago by eagleli123 <[email protected]>

[Improve] Yarn request retry improvement (#3217)

Co-authored-by: benjobs <[email protected]>

fe98be89f4333d7bc7016ebd580dcf4b1c2363a2 authored about 1 year ago by benjobs <[email protected]>

[Improve] maven-wrapper downloader improvement (#3214)

5755289c76bcfb97bf7b5914218ce06300d86229 authored about 1 year ago by benjobs <[email protected]>

[Improve] Upgrade maven-wrapper to 3.2.0 (#3213)

da5957600a705c84affcffdcece5bf045bcea040 authored about 1 year ago by benjobs <[email protected]>

[Bug] Flink job modify_time change with duration bug fixed #3188 (#3211)

* [BUG] Flink job modify_time change with duration bug fixed #3188

* minor improvement

* R...

809eda861e3e6e1a1c78c7a0f098e71add275ec6 authored about 1 year ago by benjobs <[email protected]>

[Improve] Storage Initialize create python directory (#3206)

* [Improve] Storage initialize create python dir

106160b630952a00b0248ddb6eb2bb815ca7c6f3 authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] [Flink-Kubernetes-V2] Change doTriggerSavepoint log (#3199)

* [Improve] Change doTriggerSavepoint log

* change log

* Update KubernetesClientV2Trait.sc...

2fc895d1b75b3d194b967c5c7964d0079facde89 authored about 1 year ago by caicancai <[email protected]>

[Improve] System module code optimization (#3197)

* [Improve] System module code optimization

* [Improve] Console core module code optimization...

9cbece6ea269a451bc4ef79b08f658d497470736 authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] Console core module code optimization (#3202)

* [Improve] Console core module code optimization

50ee383900773664249410011c17b0f285bcc905 authored about 1 year ago by ChengJie1053 <[email protected]>

[Refactor] Refactor exception handling with ApiAlertException (#3198)

* [Refactor] Refactor exception handling with ApiAlertException

e45000129c7704bf309f475d64e2a451808e33f0 authored about 1 year ago by gongzhongqiang <[email protected]>

[Refactor] Refactor ObjectUtils and CommonUtils (#3201)

Co-authored-by: gongzhongqiang <[email protected]>

c032163d467fd593d066cc85cc674f6cd30e9ff1 authored about 1 year ago by gongzhongqiang <[email protected]>

[Feature] Add id to ShutDownRequest (#3191)

3b9abd3df145d2c722fc86390bddf7901cb4b0d0 authored about 1 year ago by caicancai <[email protected]>

[Improve] Add Local Development and Debugging to Readmd document (#3195)

* Update README.md

* improve

49a16e7b045c58c0cc29d75c7e1aa0bc7fc9c26c authored about 1 year ago by caicancai <[email protected]>

[Polish] Remove redundant @Transactional annotations (#3190)

6b3407479c5273c8662a3f09484c08ce467498f9 authored about 1 year ago by gongzhongqiang <[email protected]>

[Improve] Package name improvement (#3170)

* [Improve] Package name improvement

* [Improve] Clone project minor improvement

d6d07c370cb8f2b76fdcbcf2567ea2aee98bc079 authored about 1 year ago by benjobs <[email protected]>

[Improve] Authentication code optimization (#3187)

* [Improve] Authentication code optimization

* Modify pgsql-schema.sql

* delete SysLog

fb1f42bcfa7e2d33cc2f7319c65a83ddde10096f authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] GitUtils code optimization (#3183)

* optimized code

* Formatted code

361990519f0e8fb5db98a5a90aea450794df9870 authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] Enumeration improvement (#3182)

* [Improve] Enumeration improvement

* enum minor improvement

093a57dd5ed100b4ef134797e75b8e69ac939c73 authored about 1 year ago by benjobs <[email protected]>

[Improve] Unified Naming Rules for Enumeration Classes (#3133) (#3175)

* [Improve] Unified Naming Rules for Enumeration Classes (#3133)

2274d5502d529fc7f0ab7e12841b1841082ae335 authored about 1 year ago by xsymin <[email protected]>

Naming standardization (#3177)

436b9f320184dbc85320d6a45b26bda84ddce855 authored about 1 year ago by caicancai <[email protected]>

[Fix] Modify the isPythonFileType parameter (#3176)

16d39f931ecb23de14dbcaf30b8f73e64102c6da authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] Streampark-common module tika dependency moved to the streampark-console module (#3171)

* [Improve] Streampark-common module tika dependency moved to the streampark-console module

*...

d2a10d604585e521268691a6df6ab0a201fdf94c authored about 1 year ago by ChengJie1053 <[email protected]>

[Improve] optimize enum RestoreMode getName function (#3173)

027172c17b4720a22511af517485cf5a4596f22c authored about 1 year ago by VampireAchao <[email protected]>

[Improve] Improve streampark-common module base on [3.9 Java Streams] (#3174)

63e1787071868111c379e3bd6b7aea3a1ada1dc6 authored about 1 year ago by VampireAchao <[email protected]>

[Improve] Alarm minor improvement (#3168)

13ef831eec3ab019fa050ffc9452ea2e5b743243 authored about 1 year ago by benjobs <[email protected]>

[Fix] Interceptors add /resource/upload (#3154)

* [Fix] Interceptors add /resource/upload

* Modify message

* Modify FileUtils

* Modify ...

18b5cd8903eba994439f4d3d3fc34a8ca4abd003 authored about 1 year ago by ChengJie1053 <[email protected]>

[ISSUE-3044][Improve] Improve streampark-common module base on 3.1 Naming Style (#3130)

* [Improve] Improve streampark-common module base on 3.1 Naming Style

60c50918dc7da9abe69a10a4290cee2dc1f74366 authored about 1 year ago by Kick156 <[email protected]>

[Feature] Add application backup clean task (#3160)

7a7e66d28925587beccbbcebf96ddb18bc20534d authored about 1 year ago by gongzhongqiang <[email protected]>

[Fix] Fix the issue of Scala calling Mybatis LambdaWrapper with Java function reference (#3164)

* [feat][flink-k8s-v2] Migrate the creation process of the flink deploy ingress to the Flink kub...

9502711cca4488bbaa3a974897570ab6671c6456 authored about 1 year ago by Linying Assad <[email protected]>

improve README.md (#3156)

4e7b53de9898b9c5210f81d1c947c472b9974f79 authored over 1 year ago by caicancai <[email protected]>

[Improve] Add additional use cases for FlinkOperator on Kubernetes (#3152)

* add test

* Change namespace

3f401a09ac5f5af83c8f1ea24776f4748885de44 authored over 1 year ago by caicancai <[email protected]>

[Improve] FlinkAppHttpWatcher improvement (#3150)

d29447884ff59b09b526f267845617e37269033c authored over 1 year ago by benjobs <[email protected]>

remove assembly.xml _${scala.binary.version} (#3151)

faa4e0fcaba4a870894e58f5a7d2dadbf64c4913 authored over 1 year ago by liuenci <[email protected]>

add how to Contribute (#3148)

145a2707e6fe139f94a144706bbe9037d36bfa09 authored over 1 year ago by caicancai <[email protected]>

[Bug] The incorrect for loop writing method resulted in the same values for the three podTemplates in k8s mode. (#3144)

Co-authored-by: 王可帅 <[email protected]>

d8c071422a8d9ddd12da62fdc5faa69b5884aa2f authored over 1 year ago by wangkeshuai1 <[email protected]>

[Improve] Shims base module code optimization (#3141)

* [Improve] Shims base module code optimization

* Modify SqlClient

598d36e5259b42a6eb5d4ee8827873e0ffead745 authored over 1 year ago by ChengJie1053 <[email protected]>

[ISSUE-3142][Improve] Extract the exception utils methods into ExceptionUtils. (#3143)

* [ISSUE-3142][Improve] Extract the exception utils methods into ExceptionUtils.

* Add licens...

eb5de31017d2dd7573bfe3486ad51d9c17f0b733 authored over 1 year ago by Yuepeng Pan <[email protected]>

[Cleanup] Remove the package org.apache.streampark.common.tuple of streampark-common module. #3132 (#3139)

* [Cleanup] Remove the package org.apache.streampark.common.tuple of streampark-common module. #...

d1da08c7e52eab4a1d3b833dd30185ff60de303b authored over 1 year ago by ligen <[email protected]>

[ISSUE-3129][Improve] Unified enumeration comparison methods (#3135)

* [ISSUE-3129][Improve] Unified enumeration comparison methods #3129

---------

Co-author...

4b9d8817d9a7044e38523c6acb74b54c609bc7d8 authored over 1 year ago by xxt <[email protected]>

[Cleanup] Remove the redundant Serializable implementation for all Enums of the project. (#3131) (#3137)

Co-authored-by: ligen60 <[email protected]>

367c6af33a82f0b7c33f1c1ffa24d0499aa1400d authored over 1 year ago by ligen <[email protected]>

Modify savepoint parameter name (#3134)

7274224781a70287056b7f067e72b02883dc05c7 authored over 1 year ago by ChengJie1053 <[email protected]>

[Feature] Flink remote support pyflink maven dependency (#3124)

* [Feature] Flink remote support pyflink maven dependency

* Modify FlinkRemoteBuildPipeline

ae9a9e16ff177bbbcd447e01d25ff72e83c55d80 authored over 1 year ago by ChengJie1053 <[email protected]>

[Improve] Application state improvement (#3128)

d7166dcd6e696cc8c8c339fdb8dcbc569682e641 authored over 1 year ago by benjobs <[email protected]>

[Feature] StreamPark Autonomous Health Probing (#3036)

* [Feature] StreamPark Autonomous Health Probing

332c6756be4d2942929a1e6e5f15fe4ae8e3098e authored over 1 year ago by xujiangfeng001 <[email protected]>

[Improve] project page improvement (#3127)

eeb0f1b35770d8cfd6ede6971587261f057bd4da authored over 1 year ago by benjobs <[email protected]>

[Improve][All] Improvement of StringUtils.isEmpty method (#3126)

512b607eb8681d067b2ab28af7dc7b05ae2d31ee authored over 1 year ago by ChunFuWu <[email protected]>

[Improve] Improve streampark-console module base on [3.2 Constant Variables Definition] (#3121)

* [Improve] Improve streampark-console module base on [3.2 Constant Variables Definition]

* f...

269b6b7944fd33b8c24b0b9958b60877e0994d95 authored over 1 year ago by ChunFuWu <[email protected]>

[Improve] project clone openssh higher version improvement (#3125)

297867b54f36c1369d22b39a475b8ea3886e8998 authored over 1 year ago by benjobs <[email protected]>

fix: app create err & fix type error (#3123)

* fix: app create err & fix type error

* build: engines

a4d06175dd85e8a1f5d241e509cfc635f4fa09a7 authored over 1 year ago by Kriszu <[email protected]>

[Improvement] FE enums improvements (#3082)

b6985d06875bbfbee60cc686bdae6a146ee46e2b authored over 1 year ago by benjobs <[email protected]>

[Improve] RestResponse fail method improvement (#3122)

* [Improve] RestResponse fail method improvement

* [Improve] formatter improvement

-------...

c102cc7ebee7ba85241326cef86f74dd0d917f0e authored over 1 year ago by benjobs <[email protected]>

fix buji-pac4j dependency issue (#3080)

ee6e08ec5b7f2b29a510280aeeee1f76ede09c2c authored over 1 year ago by Killua <[email protected]>

[feat][flink-k8s-v2] Migrate the creation process of the flink deploy ingress to the Flink kubernetes operator (#2879) (#3054)

d736d2b64a1b13fbb4b18b883b9c08cf53d08e99 authored over 1 year ago by Linying Assad <[email protected]>

[feat][flink-k8s-v2] Update the helm configs to support embedded file server. (#2886) (#3053)

2d95ad58392ef0ba1559f1044c58191bf424b3e1 authored over 1 year ago by Linying Assad <[email protected]>

[Bug] workspace path init bug fixed (#3052)

* [Improve] init workspace path improvement

* minor improvement

---------

Co-authored-...

3e86bd103ccdd48e8b0b1077ae42cb1eb87bc0fe authored over 1 year ago by benjobs <[email protected]>

fix getService bug (#3031)

0049916a768e688c3bb8dc76a6d466968940ba5a authored over 1 year ago by xiebin <[email protected]>

[Feat][Flink-K8s-V2] Adaptation of snapshot tracking for Flink on Kubernetes (#3048)

* [Feat][flink-k8s-v2] Optimize the Flink state subscription code. #2885

* [Feat][flink-k8s-v...

c3c6f3dd4063a505ab926c3c209f390266695bf1 authored over 1 year ago by Linying Assad <[email protected]>

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark