github.com/apache/incubator-streampark commits

[improve] on k8s mode get flinkMetrics improvement

65a8260ad4719cda28235c7a2e02ba0ceb4d6782 authored over 2 years ago by benjobs <[email protected]>

Solving the problem of stuck status (#1254)

* Solving the problem of stuck status

* Update FlinkJobStatusWatcher.scala

89e72b2811e69b8c21e61f453011b5eae7561b6a authored over 2 years ago by Monster <[email protected]>

repair FileUtils.equals() (#1252)

Co-authored-by: hujian.wang <[email protected]>

5a95bd6083f645b1bb47abb80980374b07d23083 authored over 2 years ago by benjobs <[email protected]>

[Feat] deploy flink on k8s mode get checkpoint support

99c3eed4d977bb3d3183463c4036fb0c585117c9 authored over 2 years ago by benjobs <[email protected]>

Add Alert Test (#1241)

* lark alert test added

Co-authored-by: weijinglun <[email protected]>
Co-authored-b...

15f4b83316a8a82b9898dfbc745a4524f987a124 authored over 2 years ago by xxyykkxx <[email protected]>

[Improve] k8s ingress configuration improvement. (#1240)

* [Improve] k8s ingress configuration improvement.

ba233674fd57327b5eabe0437d155e5d86275cb1 authored over 2 years ago by benjobs <[email protected]>

[Improve] savepointPath check improvement.

7a51d17daee5996017820d10e231c65822482da7 authored over 2 years ago by benjobs <[email protected]>

[Improve] Update upgrade.sql to save history email alert conf (#1236)

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

8d4a25ef0de63ee12ad86a5147a692cf936e413e authored over 2 years ago by 小狐狸 <[email protected]>

[Improve] flinksql syntax improvement and testcase added (#1237)

a7d0a10ef8da4a4e37a1e63d3201a5b7e3c27d9c authored over 2 years ago by benjobs <[email protected]>

more sql type support (#1232)

* junit 依赖

* 1. 只特殊处理一些无法使用 executeSql() 函数处理的 sql 语句，剩下的全部使用 executeSql() 函数处理
2. select语句暂...

a9042f61b0bba856c95abfe0beeafe4695e5aca9 authored over 2 years ago by 第一片心意 <[email protected]>

Lark Alert (#1233)

* lark alert support

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

4fd4112164aa166dce224cf6be30a379efcb8c0f authored over 2 years ago by xxyykkxx <[email protected]>

token and restapi page added (#1229)

* token and restapi page added

5135e4f0617881d39b65ddae47efa880de7bece3 authored over 2 years ago by benjobs <[email protected]>

[Bug] status filtering for application-list-page is not available bug fixed #1199 (#1228)

* [Bug] status filtering for application-list-page is not available bug fixed #1199

f432da098b1578a03d57409b984a9775eb53ae5d authored over 2 years ago by benjobs <[email protected]>

[Improve] search box move to top and quickly retrieve job support

1718302d023c36f9ecdd5a3b74a05bb86797d525 authored over 2 years ago by benjobs <[email protected]>

[Improve] change app name synchronously when changing k8s-clusterId (#1221)

* [Improve] change app name synchronously when changing k8s-clusterId

c0b9357a6cbe0771d3728a782299abad91d895b8 authored over 2 years ago by benjobs <[email protected]>

[Improve] check savepoint path improvement.

22479eba396462165dc244ad80ca68e297c395ea authored over 2 years ago by benjobs <[email protected]>

[Feature-1185] Task list add last modified time option. (#1217)

1b4c57d000077e38a8d58cf4ad80d62e56918a90 authored over 2 years ago by lvshaokang <[email protected]>

[BUG] parse create function syntax bug fixed. (#1216)

18bd3304525c9c71d7ed134b47450ed5a212e897 authored over 2 years ago by benjobs <[email protected]>

add ingress configuration (#1213)

ac787181f5d0be8a8d95856ab378f14a8bc43a63 authored over 2 years ago by Monster <[email protected]>

[Bug] flinksql segmentation SQL fragment sorting error fixed (#1214)

adc08ee8c4cb91619bbc8ea380dd13e5d654acc6 authored over 2 years ago by benjobs <[email protected]>

Add macksonmu (#1212)

* fix:[Bug] When streamx stops a task, start savepoint, but the savepoint path is not required #...

38c83c8422f0b10336541f7e1d6826dfbf0a6f5c authored over 2 years ago by macksonmu <[email protected]>

[Bug] Execution bug caused by sql fragments split by flinksql not sorted in order (#1210)

1ceb92626f036a4dd8f988e4c47fc2d90bce7016 authored over 2 years ago by benjobs <[email protected]>

[Improve] flinksql syntax improvement and flinksql testcase added.

3f14ce1cb1766571d8b14f9f9099812328597692 authored over 2 years ago by benjobs <[email protected]>

支持所有类型 sql 解析 (#1188)

* junit 依赖

* 1. 只特殊处理一些无法使用 executeSql() 函数处理的 sql 语句，剩下的全部使用 executeSql() 函数处理
2. select语句暂...

2bbdbc3cc95f57731a589562097e28e98713e924 authored over 2 years ago by 第一片心意 <[email protected]>

Merge branch 'connector' into dev

3f817afaf136da6d6f300a25e54ac6fa5ea7a0e5 authored over 2 years ago by wangqingrong <[email protected]>

fix:[Bug] The result records searched on the project list page will be periodically rewritten and reset #1162 (#1184)

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

4a18904f3714fbdb9194ce278934cd214cbe4984 authored over 2 years ago by macksonmu <[email protected]>

Support for helm build streamx on k8s (#1151)

* add helm

* Update Dockerfile

* Some minor changes to the documentation

03c1538ba4156457b5eec084c67dc7079037567d authored over 2 years ago by Monster <[email protected]>

bug fix (#1183)

bee211c408da9677ebd31ee2b08eda04a636c156 authored over 2 years ago by Monster <[email protected]>

add ldap login (#1181)

* add ldap support.

0d4021b23d7b12bb3f71cc7b1923e9add57c912b authored over 2 years ago by Monster <[email protected]>

[bug] yarn knox proxy unnecessary kerberos auth, just for page redirect (#1154)

* [bug] yarn knox proxy unnecessary kerberos auth, just for page redirect

cf76af05f4634633760c7cfbeb0330d3aecfcc13 authored over 2 years ago by atovk <[email protected]>

[Bug] submit flink job argument type mismath #1165 (#1182)

* [Bug] submit flink job argument type mismath #1165

1391ed9dea9eb564cb871f53a788f4e5a81f6658 authored over 2 years ago by benjobs <[email protected]>

[Improve] streamx-console env init improvement (#1179)

2631794f19524fd90d40b494724fc1db34a8eea4 authored over 2 years ago by benjobs <[email protected]>

[Bug] Flink auto recover taskmanager failed #1175 (#1178)

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

b15d453d6604c6a3364c67d50997ec12ad56370b authored over 2 years ago by chuanchuan <[email protected]>

fix:[Bug] project Item list cannot be flipped #1048 (#1172)

8af0277d90558ad2ca203a9410cb551430406dc9 authored over 2 years ago by macksonmu <[email protected]>

[Feature] verify flinksql support hive Dialect (#1170)

a69032216e99cb17490565a0608870fe2e46957a authored over 2 years ago by benjobs <[email protected]>

[Feature] The app list displays the user #1164 (#1167)

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

2481c7e1ce4581427f2a39ac2610b94d44697cda authored over 2 years ago by macksonmu <[email protected]>

Fix the bug of pom display (#1159)

1ca7b21fb2f820eef45f37ea38f5917881493399 authored over 2 years ago by teeyog <[email protected]>

[Improve] flink SQL error line number improvement (#1161)

578d24792161832db91830dc89fbef56e9e03449 authored over 2 years ago by benjobs <[email protected]>

[Bug] Dynamic Option EOF while looking for matching """ (#1157)

* [Bug] Dynamic Option EOF while looking for matching

92f851b71277b963c4f32692fd711c91c4c746ac authored over 2 years ago by benjobs <[email protected]>

[Improve] flink SQL syntax verify improvement (#1156)

* [Improve] flink SQL syntax verify improvement

a1f3b0ae627fde59e13038e6f5bf9fab975d8275 authored over 2 years ago by benjobs <[email protected]>

[update] shiro-spring version to 1.9.1 (#1153)

2681afcca8b118a8e5a422a118881e8494b17358 authored over 2 years ago by wangrui <[email protected]>

fix hadoop conf rewrite time value end by 's' (#1152)

664ca006716897a1af7dd75fbc835720e6e5cb01 authored over 2 years ago by atovk <[email protected]>

[Update] add feishu alert (#1137)

* [Update] add feishu alert

* [improve] alert model config improvement

* [bug] send feishu...

39b15898f2fbd3f1667fa5bb6504bed2050c8d8b authored over 2 years ago by 小狐狸 <[email protected]>

[Bug] Unsupported FileSystem s3, yarn.provided.lib.dirs add flink plugins #1134 (#1149)

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

01a76753c5b17341c3616c9f82de26347748b8bd authored over 2 years ago by chuanchuan <[email protected]>

Enhanced doris streamx connector (#1123)

* Enhanced doris streamx connector

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

88e68a8db16476dd0b568fc80699845a7fd9c541 authored over 2 years ago by wangqingrong <[email protected]>

[Improve] Improved Flink SQL syntax validation to accurately display error locations (#1147)

* [improve] Improved Flink SQL syntax validation to accurately display error locations

72a807a3468c3407087f9d58847fd196ae16bacc authored over 2 years ago by benjobs <[email protected]>

[bug] send alert job' monitor-url bug fixed.

6c8b5f35e4c1f1c090f1fecec72bf96731923494 authored over 2 years ago by benjobs <[email protected]>

Create CODE_OF_CONDUCT

7854df9b2d2ac5d2c714e19745700b3379909298 authored over 2 years ago by benjobs <[email protected]>

[improve] feishu, dingtalk icon added and alert page improvement. (#1138)

* [improve] feishu, dingtalk icon added and alert page improvement.

49d9d642ba9ffb04d1051f9a726794f3e97d3892 authored over 2 years ago by benjobs <[email protected]>

Enhanced doris streamx connector

02087bc9f9d588491da1405d2ca321db0e021f09 authored over 2 years ago by wangqingrong <[email protected]>

[improve] alert page improvement. (#1136)

* [improve] alert page improvement.

a3af3ccd7406349528e46fd68c584bc5e3fbf948 authored over 2 years ago by benjobs <[email protected]>

[Feature] system setting item grouping and classification #1130 (#1131)

ccb44ee685148e0782680292ff5cfa7badccb39a authored over 2 years ago by benjobs <[email protected]>

Review DingTalk PR，add alert management (#1129)

* add DingTalk WeCom HttpCallback alert service, add t_alert_conf table and controller

* Merg...

ff6da0ca260a5773dae9cc0803d62de254da5756 authored over 2 years ago by xxyykkxx <[email protected]>

[bug] when launch job check job rebuild bug fixed. (#1124)

* [bug] when launch job check job rebuild bug fixed.

896f78c8231a7fad55dfb537da7b3e4cdb0b3cd9 authored over 2 years ago by benjobs <[email protected]>

Enhanced doris streamx connector

5d060d5d95345cec3af904ba35b4452759bf940a authored over 2 years ago by wangqingrong <[email protected]>

Enhanced doris streamx connector

2eb22b3dd8b097e628772b6523893f4b75a3b78c authored over 2 years ago by wangqingrong <[email protected]>

Enhanced doris streamx connector

f3d81c22a9f9ec333758e9e3c50295709412ad6d authored over 2 years ago by wangqingrong <[email protected]>

Enhanced doris streamx connector

8f8dd9f02ba6c25fbf97e3fa275155adb8993c9d authored over 2 years ago by wangqingrong <[email protected]>

[Improve] k8s mode rebuild optimization, jump to flink dashboard ui bug fixed

9e303a7b6ee37fd28709275b5703cd7397c91def authored over 2 years ago by benjobs <[email protected]>

[Improve] docker image namespace optimization. (#1114)

* [Improve] docker image namespace optimization.

1300f08e5d3412c011a25a1c4bb678288ecd279d authored over 2 years ago by benjobs <[email protected]>

Update README.md

fa4ecaa0cc4d31b9fa7dc6a5f2f4bd263b5fbb3d authored over 2 years ago by benjobs <[email protected]>

flinksql verify sql bug fixed. (#1110)

e8338979a509077e205a9548bb7797213e1a3f9b authored over 2 years ago by benjobs <[email protected]>

flinksql syntax parser bug fix

* flinksql syntax parser bug fix

47b5e29b50db2253b68e9d5851b6833c6d5b45bc authored over 2 years ago by benjobs <[email protected]>

[Bug] k8s pod-template cannot enter content bug fixed. (#1102)

* [Bug] k8s pod-template cannot enter content bug fixed.

c45a993781ce1c9aaf8b7b93f6b7035268e16f5e authored over 2 years ago by benjobs <[email protected]>

get job state bug fixed. (#1101)

* get job state bug fixed.

ca02bf6f31a343915a58d607be726496cf45f589 authored over 2 years ago by benjobs <[email protected]>

HadoopUtils and YarnUtils improvements (#1093)

* HadoopUtils and YarnUtils improvements

9f74d8cf0f9b67aaf625f38fc248d265c2ee2bc7 authored over 2 years ago by benjobs <[email protected]>

update version to 1.2.4 release (#1091)

285c5e85dfa4ca24b031cc179b9b5ae88e0fa1f5 authored over 2 years ago by benjobs <[email protected]>

kerberos httpclient support (#1090)

* job forced stop support.

* kerberos httpClient support.

4b70bcffa5088ad27fa53c52dc7a5469578f14ad authored over 2 years ago by benjobs <[email protected]>

job forced stop support. (#1089)

0782d4580ddc07d363c5be6d2b0062552572d68b authored over 2 years ago by benjobs <[email protected]>

print log when update setting failed (#1087)

e411e9e8b4d48dda466e41196a3d520196a9d67d authored over 2 years ago by zhuzhihao94 <[email protected]>

typo fixed (#1079)

* typo fixed

49de502fe23d716f2f502e057b14f27b583d08d9 authored over 2 years ago by benjobs <[email protected]>

[Bug] http client default auth #1075 (#1078)

58aa9ef5a04d0c0db5b06ad8fb5c9c922612bbf3 authored over 2 years ago by atovk <[email protected]>

should build app when all changed (#1077)

* should build app when all changed

a7f4af774a788c5d487a114ab9542e8a8181e105 authored over 2 years ago by zhuzhihao94 <[email protected]>

Fix docker in docker issue (#1076)

27cb6270bce6cea731e2bd1513dfc384d1c368b7 authored over 2 years ago by Monster <[email protected]>

[Bug] yarn kerberos acl #1046 (#1053)

* add kerberlized http request

* [BUG]kerberos getLoginUser error.#1030 (#1055)

* [Feature...

0928cc735ca809e139bf7a95b7ed638449495872 authored over 2 years ago by atovk <[email protected]>

[Feature] Add github action to connect with docker hub, add docker compose (#1016)

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

92e870773695d15060a643cbb6d49c036175a039 authored over 2 years ago by Monster <[email protected]>

[Bug] [FLINK-27299] flink parsing parameter bug fixed. (#1067)

* [Bug] [FLINK-27299] flink parsing parameter bug fixed.

e238ed8094d42645bb4e7977a557aa4eda63880a authored over 2 years ago by benjobs <[email protected]>

[improvement] sql convert improvement (#1066)

* [improvement] sql convert improvement

6c6e8e24a43d370e2e1f9003811cb58e86d94e81 authored over 2 years ago by benjobs <[email protected]>

[Bug] find jar in error path #1060 (#1064)

find jar in all path ,all path don`t have jar ,throw exception.

Co-authored-by: XieChenling <...

10b31679a8a24eff1d1a0a6f74021263ff903da4 authored over 2 years ago by ChenlingXie <[email protected]>

[Bug] Taskmanager memory usage statistics calculation error on yarn mode #1061 (#1065)

calculate memory use taskmanager number

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

cf6636c2488d347ec7245e364b77661bcadf748e authored over 2 years ago by ChenlingXie <[email protected]>

[improvement] HDFS-10845 improvement (#1059)

dd8c05106b1950a86d84954c949df3c5a399ef91 authored over 2 years ago by benjobs <[email protected]>

[BUILD][TEST] Fix and enable UT on GitHub Action (#1040)

* Fix and enable UT on GitHub Action

* typo

31b6a81a33c858ab2e7978a41950896a1670d758 authored over 2 years ago by Cheng Pan <[email protected]>

[Feature] knox proxy cluster #1044 (#1052)

* [feature] profile key add knox proxy prefix

* config name friendly

Co-authored-by: lzyyy...

9b002702381d8bea06aa9fc458dc43e2e88c26f2 authored over 2 years ago by atovk <[email protected]>

[BUG]kerberos getLoginUser error.#1030 (#1055)

eccfd739228e667f71e5311228d00b524f6bfc3c authored over 2 years ago by dian <[email protected]>

[Bug] branch authentication error bug fixed.(#1038) (#1043)

7e009acd1d74041ea9a22368ee070912186f76af authored over 2 years ago by rafaelxie <[email protected]>

[Bug] expireTime bug fixed (#1036)

* [Bug] expireTime bug fixed

2ed436630290e7cb8cbeb26dad3642681d50aedf authored over 2 years ago by benjobs <[email protected]>

update version to 1.2.4 (#1035)

3ebdaf2b0b6e5d39c11f0ecc00da0d175eff11dc authored over 2 years ago by benjobs <[email protected]>

[Bug] Dynamic Option not support jvm params#1022 (#1023)

* [Bug] Dynamic Option not support jvm params #1022

Co-authored-by: weijinglun <weijinglun@mi...

d114fc66d08a7c674075c55f5c5dce5cb9382203 authored over 2 years ago by xxyykkxx <[email protected]>

[Feat] build script support. (#1021)

* [Feat] build script support.

311d96261efe073953a1195d4c845429b48bb2a2 authored over 2 years ago by benjobs <[email protected]>

[Feat] build script support. (#1020)

a0d717d1260ae2c153d15f9e28438fb56c1cd2a6 authored over 2 years ago by benjobs <[email protected]>

[Improve] maven dependency optimization (#1014)

* [Improve] maven dependency optimization

d2899bbc171e1d642c654f0931e9532ab3c29da1 authored over 2 years ago by benjobs <[email protected]>

README added "contributor Over Time" (#1013)

* Update README_CN.md

8aadfaebb5c77f062dd6c5f01b9274ed478b86e0 authored over 2 years ago by benjobs <[email protected]>

[hotfix][docs] Fix typo in the "FlinkStreamingInitializer.scala". (#1012)

6a37983da855e9022ad64d4cb27f59bcc1045b07 authored over 2 years ago by liuzhuang2017 <[email protected]>

[Feat] flink 1.15 support. (#1010)

* [Feat] flink 1.15 support.

3ff5e6e06d9bfb30fbc592084ca30421bb857ff4 authored over 2 years ago by benjobs <[email protected]>

[Feat] flink 1.15 support. (#1007)

* [Feat] flink 1.15 support.

8bf41eb74a8ce8b6f6a5e27ff7fa8d3d24ad6d3e authored over 2 years ago by benjobs <[email protected]>

[Feat] flink 1.15 support. (#1006)

* [Feat] flink 1.15 support.

fb5e67cd14a835a6a6a8dc77f7d594e8fa0ea13e authored over 2 years ago by benjobs <[email protected]>

[Feat] flink 1.15 support. (#1005)

* [Feat] flink 1.15 support.

fa0ab6996b07ea6e48ab1db79904701e0d6ea3e2 authored over 2 years ago by benjobs <[email protected]>

[hotfix] open API expireTime bug fixed. (#1004)

* [hotfix] open API expireTime bug fixed.

d2b29e8cb2c98d07a673da64f2682aeea63eb6bf authored over 2 years ago by wangrui <[email protected]>

[Feat] flink 1.15 support. (#1003)

ea00e39c2bcbbcbb630abf59f0944911b3c8cc5b authored over 2 years ago by benjobs <[email protected]>

sql adapte to 1.2.3 (#1002)

* scala code style optimize

* sql adapte to 1.2.3

8386d00c800d0cf0e1975a9c6dce2507b1599253 authored over 2 years ago by benjobs <[email protected]>

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark