Ecosyste.ms: OpenCollective

An open API service for software projects hosted on Open Collective.

github.com/apache/incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://github.com/apache/incubator-streampark

[Improvement] add support for SinkRequest that has multiple statements (#3004)

* add support for SinkRequest that has multiple statement

* Update imports of ClickHouseWrite...

aa320d163a536f7d62ad58eef52db66a7ececad4 authored over 1 year ago by lenonhere <[email protected]>
[Feature] [Flink-K8s-V2] Refactor the lifecycle control of Flink session-mode jobs on Kubernetes (#3041)

* [Feature] [Flink-K8s-V2] Refactor the lifecycle control of Flinksession-mode jobs on Kubernete...

232d93f1fb65a2e1ae2bc1148a3e15c74845c5b4 authored over 1 year ago by caicancai <[email protected]>
Flink yarn application support pyflink maven dependency (#3042)

4754e92918b1832ee41442d4d0c2bfaae64b7111 authored over 1 year ago by ChengJie1053 <[email protected]>
[Improve] EnvUtils minor improvement (#3040)

48838c5e8891e0897369f9cc129d09d14408fb6d authored over 1 year ago by benjobs <[email protected]>
[Feature] [Flink-K8s-V2] Refactor the state tracking of Flink on Kubernetes (#2989)

* Refactor the state tracking of Flink on Kubernetes

* Refactor the state tracking of Flink o...

dd4061d7214a42143f3265e967fde50f295a0d4a authored over 1 year ago by ChengJie1053 <[email protected]>
[Hotfix] Fix non-existed methods references and exceptions-thrown. (#3039)

832908ac61014379ef806b3db95f55585deb5420 authored over 1 year ago by Yuepeng Pan <[email protected]>
[Hotfix] Code style update (#3038)

be1409ca7a7477ec9433076fe721951d4cb524a8 authored over 1 year ago by VampireAchao <[email protected]>
[Feat][Flink-K8s-V2] Refactor the lifecycle control of Flink K8s application-mode jobs (#3037)

* [Feat] Refactor Flink resource build pipeline for fink-k8s-v2 module. #2882

* [Feat] Adapta...

11c7fa8377398b09e052c046c16d209974e2fce0 authored over 1 year ago by Linying Assad <[email protected]>
[ISSUE-2992][Improve] Using code style & quality rules to improve org.apache.streampark.console.base.config package of streampark-console module. (#3012)

* extract string as constant

* code style format

* define it directly instead of using con...

65d968f68d0c25dcedc072a49660bca0481f5911 authored over 1 year ago by eaglelihh <[email protected]>
[Improve] Remove redundant serializable implements for enum (#3025)

* [Improve] Using code style & quality rules to improve org.apache.streampark.common.enums packa...

0d61f5d4bbc21673fe269025cdfafe2b211b0bb6 authored over 1 year ago by VampireAchao <[email protected]>
[Refactor] Refactor alert module. (#3023)

* [Refactor] Refactor alert module.

* address comment

4390d0693e7afe3a2b26241639005b6ffed4a5f7 authored over 1 year ago by gongzhongqiang <[email protected]>
[Hotfix] Disabled unstable test cases. (#3034)

15df598824292182d2cd5bc21f48ceabfe0e6809 authored over 1 year ago by Yuepeng Pan <[email protected]>
[Enhance] Optimize the validation logic of flinkDeploymentCR at PR#2966. (#3032)

ae08fae52b001059b31ecde397f5a74391915ebb authored over 1 year ago by Linying Assad <[email protected]>
Refactor the lifecycle control of flink application mode -dosubmit (#2994)

* remove scala2.11

* [Feature] [Flink-K8s-V2] Refactor the lifecycle control of Flink applica...

8ff30e3de6c233adc5601839aaa73c4d39bc78cd authored over 1 year ago by caicancai <[email protected]>
Added flink k8s operator validate (#2966)

* Added flink k8s operator validate

* Code optimization

* Modify flink k8s operator valida...

23b191fdc7af9b2cf29467d4d58c426eae793f69 authored over 1 year ago by ChengJie1053 <[email protected]>
[Improve] Using code style & quality rules to improve org.apache.streampark.common.enums package of streampark-common module. (#3019)

4eeeb6f6b89d63a7baad94fbeb0ec9c9ceeebcb4 authored over 1 year ago by VampireAchao <[email protected]>
slim the pac4j package (#3017)

77ddb3683991e52f142ff9a61cf1f04931b28c61 authored over 1 year ago by Leomax_Sun <[email protected]>
fix pyflink bug (#3016)

b38079157c532a43bf9473776e68382361c0739a authored over 1 year ago by ChengJie1053 <[email protected]>
[Improve] Pyflink improvement (#3014)

* [Improve] pyflink improvement

* [Improve] pyflink improvement

* Delete ApplicationService

36fea232320caa03ff1c58753b535a790a24d3c3 authored over 1 year ago by benjobs <[email protected]>
[Improve] Application service minor improvement (#3015)

* [Improve] application service minor improvement

* [Improve] applicationService minor improv...

6a5e6e4e97dbf5f3fc745df7b36292acc2fd4888 authored over 1 year ago by benjobs <[email protected]>
[Refactor] Refactor ApplicationService moving it to own package and creating two interfaces. (#3009)

* Refactor ApplicationService moving it to own package and creating two interfaces.

* rebase ...

e60c86dd62b72fa972b7f9a81abe92d8f2c5f6ea authored over 1 year ago by gongzhongqiang <[email protected]>
Modify pgsql-schema.sql (#2942)

7d76fc0c4c0f0fbddacf95515b5fc2fe2f630497 authored over 1 year ago by ChengJie1053 <[email protected]>
[Improve] Packer module code optimization (#3010)

* DockerResolveProgress Code optimization

* uploadToHdfs rename

* Modified K8sPodTemplates...

2b177ea1f1ab930514725b50811e670e7ce079b7 authored over 1 year ago by ChengJie1053 <[email protected]>
[Improve] enhance login password protection (#3006)

d017ea30130159ed1ca7e2cd238985481f218035 authored over 1 year ago by Leomax_Sun <[email protected]>
[Improve] FileUtils minor improvement (#2981)

* [Improve] FileUtils minor improvement

* minor improvement

* minor improvement

* Impli...

77c4237f86a26b59ccf107bea1da085e03b0d8db authored over 1 year ago by benjobs <[email protected]>
[Feature] Yarn supports pyflink (#2956)

* yarn application supports pyflink

* yarn perjob supports pyflink

* pyflink supports flin...

e807c0e9f2f8c3507ae35870f715449928ad5de7 authored over 1 year ago by ChengJie1053 <[email protected]>
add ingress annotation: kubernetes.io/ingress.class (#2999)

a703f2c6ea385f2b958a92f9a8190554c677e48b authored over 1 year ago by blackCat <[email protected]>
[Hotfix][translation] Translate the ignored comments. (#3011)

c1a2847013ea74d902afeda26e993b308968253c authored over 1 year ago by HangC <[email protected]>
[Hotfix][CI] Fix the target flink home location setting and extend the status getter timeout. (#3003)

fd3f2e0683795f4a06dd71127fdf2e1eb7387df2 authored over 1 year ago by Yuepeng Pan <[email protected]>
fix TLS cert bug (#3001)

d7b866512f5739b58b2165ebfe2f97ac99807021 authored over 1 year ago by blackCat <[email protected]>
Add test-container utils for integration test. (#3002)

196e7f7222019f0e9fc0a783e8ba7794cdafcc74 authored over 1 year ago by Yuepeng Pan <[email protected]>
fix watch job bug (#2997)

5fd07601eda2eac234deb2011005e78c485cd40e authored over 1 year ago by blackCat <[email protected]>
[ISSUE-2988][Bug] Update helm template, fix streampark on k8s failed (#2990)

* fix ws:xxx fail

* code style improvement

* update helm templete & fix bug

* Update RE...

81c73c3503fa835fe1265a3dfebe6fd7a3c1883d authored over 1 year ago by blackCat <[email protected]>
fix ws:xxx fail (#2985)

* fix ws:xxx fail

11c05c56a5276793fa79498604ea3c3e21adf1fb authored over 1 year ago by blackCat <[email protected]>
remove scala2.11 (#2982)

e851330f359129d5e7ff2e9f1faf6758777f56f0 authored over 1 year ago by HangC <[email protected]>
Fix remote task submission could not find the jar (#2973)

5ee67396596bee51a01acae9f324ceb9b6d75f6a authored over 1 year ago by ChengJie1053 <[email protected]>
[ISSUE-2976][Bug] Flink job batchMode bug fixed (#2978)

* [ISSUE-2976][Improve] Flink job env initializer improvement

* [ISSUE-2976][Bug] Flink job b...

41cdbc36597020b8546433e40957ac577775ec9e authored over 1 year ago by benjobs <[email protected]>
[Refactor] Remove LogClientService and minor code refactor (#2979)

* [Refactor] Remove LogClientService and minor code refactor

6b00a0cee96a879f4ccff4dc0168b8f4f004619b authored over 1 year ago by gongzhongqiang <[email protected]>
Revert "[Improve] Remove Scala version in module name (#2974)" (#2977)

This reverts commit bde8214b4defe5f8c6cf3feee2681734520a4315.

6d34f2b61eceae86ea85dc081f5a61a1a500a4a6 authored over 1 year ago by benjobs <[email protected]>
[Improve] Remove Scala version in module name (#2974)

bde8214b4defe5f8c6cf3feee2681734520a4315 authored over 1 year ago by benjobs <[email protected]>
[Improve] Settings improvement (#2972)

* [Improve] settings improvement

* minor improvement

---------

Co-authored-by: benjobs ...

47a137801616ce8d7b1e7a0b8e2eabab9e57f526 authored over 1 year ago by benjobs <[email protected]>
[Improve] Restore mode minor improvement (#2971)

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

519632f4bd6a9a872277757f7abc5dca42df2d1b authored over 1 year ago by benjobs <[email protected]>
[Refactor] Refactor Setting and fix code style (#2969)

* [Refactor] Refactor Setting and fix code style

* Address comment

2eb6320e347f5cabf485ec84d1ddd9c6915c4483 authored over 1 year ago by gongzhongqiang <[email protected]>
[Refactor] Refactor multiple enum classes and update related methods to be more readable (#2965)

* [Refactor] Refactor multiple enum classes and update related methods to be more readable

6c0468ac6fb61b10c564be62caae486f73f179b4 authored over 1 year ago by gongzhongqiang <[email protected]>
[ISSUE-2936][Feature] Support flink native type savepoint (#2937)

* support flink native type savepoint

* remove some debug loggers

* fix a mistake

* ref...

edf8b4a53f5ee4bd9e2f2941bc3f11815bf97577 authored over 1 year ago by xiebin <[email protected]>
[improvement] Minor improvement (#2964)

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

f777561575ea2761a774897b42893c1f80f93ac0 authored over 1 year ago by benjobs <[email protected]>
[Bugfix]Bump commons-cli version to resolve compatibility problem under flink 1.17 (#2725)

* upgrade commons cli version to 1.5 to fix compatibility problem under flink 1.17.0

--------...

32cb49177f3ff461f9806a0385552fd9738cdb11 authored over 1 year ago by cygnusdark <[email protected]>
license header improvement (#2959)

1b1e3a9fdb63868284078f02b044adf00ab134fa authored over 1 year ago by benjobs <[email protected]>
[type:fix] Refactor AlertType class for fix cannot trigger alert (#2958)

969885f1ddcb7013cd3aa1a85e767869e9b8fcca authored over 1 year ago by gongzhongqiang <[email protected]>
module improvement (#2957)

76b41c2f39513b87ac086e5711de1106f8d196ce authored over 1 year ago by benjobs <[email protected]>
jar upload bug fix (#2948)

* jar upload bug fix

d1a31558eafede6baf20de18ebcf6f1a362dbcdc authored over 1 year ago by ChengJie1053 <[email protected]>
[Polish] Fix error msg typo (#2955)

* [Polish] Fix error msg typo

* [Polish] Polish code

---------

Co-authored-by: gongzhon...

ceaa0dcf925a8aee5927e66b9a47370ce65562d3 authored over 1 year ago by gongzhongqiang <[email protected]>
add pprint dependency (#2953)

6c5133affaab14fbdf7216bd41ea69a3fcaf57db authored over 1 year ago by HangC <[email protected]>
docker push improvement (#2952)

8f49f7aea63c91f973f2115a412736d5d50dc2e7 authored over 1 year ago by benjobs <[email protected]>
[improvement] improvement flink cluster alert (#2875)

* [improvement] improvement flink cluster alert

58709cd53b9d2db2f130ad8556230beebd6dd2d0 authored over 1 year ago by xujiangfeng001 <[email protected]>
fix: FE build script (#2947)

* fix: FE build script

* fix: script

8e9530fdc4d1f75bcdb1f34a6e6a425042cbf00c authored over 1 year ago by Kriszu <[email protected]>
docs: drop vanity metrics from README (#2946)

These photos are unstable to render that can cause negative reading experience.

Also, the num...

3b10911b1c3c7d482f2c585be006afd9d30ddf58 authored over 1 year ago by tison <[email protected]>
FlinkK8sEventWatcher remove useless code (#2938)

* FlinkK8sEventWatcher remove useless code

* PodTemplateParser code optimization

87234e58cd862550c1e7edde6082d74785ffe94e authored over 1 year ago by ChengJie1053 <[email protected]>
Extract common const FLINK_NATIVE_KUBERNETES_LABEL (#2939)

1fe20d4790ffe52d34bb03b080a31bae58783111 authored over 1 year ago by ChengJie1053 <[email protected]>
issue-2753 bug fixed.(#2753) (#2934)

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

c039b86e0f77864a8e76a7ea78befb2bf44021a0 authored over 1 year ago by zhaoningshengg <[email protected]>
fix:inserting failure when the values contain 'value' (#2932)

* fix:inserting failure when the values contain 'value'

* refactor: another fix solution

*...

e8cb2bc43e68b3e1ecd05f816f10db9891ee6124 authored over 1 year ago by caogaoshuai <[email protected]>
Fix the bugs in the test cases of flink-kubernetes-v2

73d153c28c40c6adafb38ff8d46607a6bb2508e4 authored over 1 year ago by HangC <[email protected]>
issue-2869 bug fixed. (#2924)

46e537cd9176c23efb3e177a8c7bbcaf742e9ac5 authored over 1 year ago by benjobs <[email protected]>
Restore test resources. (#2928)

97028e3eecc6304bf55a8d7588571f43f345853a authored over 1 year ago by Linying Assad <[email protected]>
[Improvement] avoid errors in batch insert caused by different tables or columns (#2919)

* avoid errors in batch insert caused by different tables or columns

Refactor sinkRequest.sq...

02adb3dd638517e89035767540ef30bd5ae1bcae authored over 1 year ago by lenonhere <[email protected]>
[Improve] flink job restore mode option improvement (#2925)

* [Improve] flink job restore mode option improvement

* check style minor improvement

ca4e05587de328fe97f62f818df3eb1397df5048 authored over 1 year ago by benjobs <[email protected]>
[Optimization] optimization RestResponse (#2921)

2565cddb3880d0e60e3f6e65ab64fa44fdee3b8e authored over 1 year ago by VampireAchao <[email protected]>
[Improve] resource improvement (#2860)

279e2d696fe96f0bc9cf709cbd8720e0fea78923 authored over 1 year ago by benjobs <[email protected]>
ClusterKey code optimization (#2920)

* ClusterKey code optimization

* FlinkCheckpointWatcher code optimization

b2ec2cd8de714387a1f723523bd088fad5c4eef0 authored over 1 year ago by ChengJie1053 <[email protected]>
menu icon improvement (#2923)

2783f0ff54432a705f8a2221530d3622ac89f974 authored over 1 year ago by benjobs <[email protected]>
dependency minor improvement (#2922)

* dependency minor improvement

* minor improvement

* rename package name

* minor improv...

d0d501c018f1a151d78d59a54d2892800e49ac79 authored over 1 year ago by benjobs <[email protected]>
[Flink-K8s-V2] Port the new module codes to Streampark-flink-kubernetes-v2 (#2916)

* Initialize flink kubernetes v2 modules. #2881

Supplement additional license statement. #288...

5be85ca123c01e1b89a54dca61b14c1d985a9752 authored over 1 year ago by Linying Assad <[email protected]>
YarnSessionClient code optimization (#2911)

* YarnSessionClient code optimization

a672ffe278bf5be8183433f8dc80b818821f3fa1 authored over 1 year ago by ChengJie1053 <[email protected]>
[Flink-K8s-V2] Create Shaded module for flink-kubernetes-operator-api dependency (#2909)

* Shaded module for flink-kubernetes-operator-api dependency #2880

* Supplement the license d...

bd66dfe0083e9a8238d37550dbd78cbb10d69e5e authored over 1 year ago by Linying Assad <[email protected]>
The YarnClientTrait add clusterClient close (#2906)

* The YarnClientTrait add clusterClient close

* Optimized code

b71e094fed373116949d471d0541d5a3182d199d authored over 1 year ago by ChengJie1053 <[email protected]>
[Feature] support for flink cluster configuration (#2905)

99fcf2931194af4750c9388812d0ae25458d8c3d authored over 1 year ago by xujiangfeng001 <[email protected]>
[improvement] improvement flink cluster verifyClusterConnection (#2903)

ac1bc0bae26bf4ab302b1a71848494e9e5b70687 authored over 1 year ago by xujiangfeng001 <[email protected]>
Modify RemoteClient log (#2908)

7232da621567e0f5b1e64cce304dfca566f178eb authored over 1 year ago by ChengJie1053 <[email protected]>
Remove FlinkClientTrait duplicate code (#2893)

* Remove FlinkClientTrait duplicate code

af0df5649bec45001942fafca5e153695592519a authored over 1 year ago by ChengJie1053 <[email protected]>
Extract common const PARAM_PREFIX (#2874)

* Extract common const PARAM_PREFIX

5e0ce99f623f2b7db527112174f8cc01c1eda16c authored over 1 year ago by ChengJie1053 <[email protected]>
[common] Tuple support (#2873)

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

3b66622d5e9d4f19a27c0c074ba54cf91fea5b5d authored over 1 year ago by benjobs <[email protected]>
SubmitRequest checkBuildResult method optimization (#2867)

9707b260ad85dd735040502cd07c66c02b92c901 authored over 1 year ago by ChengJie1053 <[email protected]>
YarnUtils Deprecated method optimization (#2866)

3d63e4fc0960edea038b765fac8d43e7db2e5e7d authored over 1 year ago by ChengJie1053 <[email protected]>
Modify CURLBuilder log (#2864)

0d5cee2a35de2a8806b106be023e13b3976dbcdb authored over 1 year ago by ChengJie1053 <[email protected]>
flink cluster improvement (#2859)

fe3f05c40a19bb1a4b1d340b4a5ed76089b60c74 authored over 1 year ago by benjobs <[email protected]>
[improvement] improvement flink cluster status update (#2858)

501a47024c9d9e193316d3de9b84a34d380823fd authored over 1 year ago by xujiangfeng001 <[email protected]>
fix: remove default Threadstacksize (#2857)

12d44d5338d782cd86733b102959143e2464ef10 authored over 1 year ago by onlyotdn <[email protected]>
[Improve]: update FE dependencies, use pnpm (#2852)

* [Improve]: update FE dependencies, use pnpm

* [Style]: eslint code

699bfbcc3d88c512825e3bc2ce4254c16d6e8cbf authored over 1 year ago by Kriszu <[email protected]>
[Fix]: monaco editor foldingStrategy parameters (#2850)

f353b9f6ccafae111a92e8e9e6d0fa642a95edbc authored over 1 year ago by Kriszu <[email protected]>
[Improve] Flink cluster status monitoring improvement (#2826)

* [Improve] Flink cluster status monitoring improvement

* flink cluster jobManagerUrl improve...

9f825706d2ef5ad354d11adbe53ed25a71f87087 authored over 1 year ago by benjobs <[email protected]>
fix: pom build error (#2846)

803fde69996b46760f1c6aa85e38bb66e667fcca authored over 1 year ago by Kriszu <[email protected]>
build: Repair the blank page problem after front-end compilation (#2845)

1e13568d8cb9b005f429ca109d652a1e2caa55d7 authored over 1 year ago by Kriszu <[email protected]>
minor improvement (#2842)

5b4bdb1625774f63226b966b82ab1de74bccf8f3 authored over 1 year ago by benjobs <[email protected]>
[FIX] sso login patch (#2841)

* [FIX] sso login prompt bug

* [FIX] add sso config for helm chart

---------

Co-authore...

688c6d99b2c34afc8927a21ad02f8fa0a12e53a8 authored over 1 year ago by Leomax_Sun <[email protected]>
[repo] Add vcs.xml for idea (#2840)

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

25ed3f3a18a079ecc4da0c622534471ac47b83d6 authored over 1 year ago by gongzhongqiang <[email protected]>
Fix typos in the code (#2839)

d51e837c275655835ecefc0ae7fd365ebd11a1eb authored over 1 year ago by onlyotdn <[email protected]>
[improve] keberos auth improve (#2834)

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

bceed8e48b5d76e84e354886d1cc5f19f007ec8d authored over 1 year ago by zhoulii <[email protected]>
[sql gateway]Implement flink native (#2737)

* Implement flink native and kyuubi sql gateway

* fix exception when fetch result with row ty...

cac931ae289e0753892279336e1c4e70e5f7d7c6 authored over 1 year ago by gongzhongqiang <[email protected]>
sso login improvement (#2824)

* sso login improvement

708f3dfccc6ecc2e589173664c69ddcfafb4af45 authored over 1 year ago by benjobs <[email protected]>
[ISSUE-2423][Feature][WIP] flink cluster failure alarm&failover (#2809)

* [Feature] flink cluster failure alarm&failover

72207f43d74bfd7eefc167effa26ebb33acb2726 authored over 1 year ago by xujiangfeng001 <[email protected]>