github.com/apache/incubator-streampark commits

[Enhancement-551]: add scala version checking when refer flink dependencies (#588)

* [Enhancement-551]: add scala version checking when refer flink dependencies (#551)

* [Enhan...

fae3137f2450d97fd9afa8bcf69a651abcb5969e authored almost 3 years ago by lvshaokang <[email protected]>

[improve] flinksql syntax validation related experience enhancement (#622)

* [improve] monaco-editor theme change improve

* [improve] simplify front-end dependencies

...

faa8969f3f73fec94965d0056b6460147f5b3de4 authored almost 3 years ago by benjobs <[email protected]>

[improve] monaco-editor theme change improve (#619)

30dbcc8ca8c709e5dd9ab7e1e010b92eee4354bd authored almost 3 years ago by benjobs <[email protected]>

2022 new slogan, new beginning (#601)

* [hotfix] guava exclude jsr305

* 2022 new slogan, new beginning

* 2022 new slogan, new be...

32929d8ac97b186205e322ac7f891d9da837de25 authored almost 3 years ago by benjobs <[email protected]>

2022 new slogan, new beginning (#600)

* [hotfix] guava exclude jsr305

* 2022 new slogan, new beginning

* 2022 new slogan, new be...

a51ac1b3b3875f81aa7eba2bdb1e550b9b9b2ab9 authored almost 3 years ago by benjobs <[email protected]>

2022 new slogan, new beginning (#598)

* [hotfix] guava exclude jsr305

* 2022 new slogan, new beginning

ea028387b784447937b644082b0c7affcdb70413 authored almost 3 years ago by benjobs <[email protected]>

[hotfix] guava exclude jsr305 (#589)

febc107bd2b74271360bbac70632ce94af4d50fb authored almost 3 years ago by benjobs <[email protected]>

#BugFixed#Fixed issue #562. The parameter jvm-metaspace.size setting is invalid, the unit should be MB, but it is actually bytes (#582)

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

82cbff7845deffc46dc66dbb1087a6015d7954dc authored almost 3 years ago by Shane <[email protected]>

maven dependency upgrade with high risk (#581)

4af9da7d6f66e9929fb6744c745275f476832668 authored almost 3 years ago by benjobs <[email protected]>

'executionMode' should be set to null and fix 'kubernetes Pods Template is not editable' (#573)

a4ecce0c204367be9247a7a05fd87d683d3d943c authored almost 3 years ago by 阿洋 <[email protected]>

maven dependency upgrade with high risk (#578)

7eaddf752ab3df5fda461f1783f2dfb7f7c8e495 authored almost 3 years ago by benjobs <[email protected]>

Merge pull request #577 from xinzhuxiansheng/hotfix01

218f37345f69a354ae6e5de37ad04cb47015ccd2 authored almost 3 years ago by Al-assad <[email protected]>

hotfix Docker-Java Client unboxToInt Exception

eaea8fd75e0abf4aa45b5197cbd2e06f65c36724 authored almost 3 years ago by 阿洋 <[email protected]>

Merge pull request #576 from xinzhuxiansheng/hotfix01

hotfix Docker-Java Client unboxToInt Exception

a06d158d738dd82a6bf71ae2ad924f96ef99fa95 authored almost 3 years ago by Al-assad <[email protected]>

hotfix Docker-Java Client unboxToInt Exception

7ce2265f9347f42e7e1314d6d8af22b8717a9670 authored almost 3 years ago by 阿洋 <[email protected]>

Improved Shiro-spring version, fixing Shiro-xxx.jar own vulnerabilities (#574)

5a947dca606eb67e25b3400abdbfdbdef1f178b0 authored almost 3 years ago by 阿洋 <[email protected]>

remove fastjson dependency. (#572)

39da1a3f0efb6ff3ebf3d35da06a62cafbc104fa authored almost 3 years ago by benjobs <[email protected]>

Improved fastjson version, fixing its own vulnerabilities (#570)

* Improved fastjson version, fixing its own vulnerabilities

* upgrade to the latest version

a9d633560301f1e508783b7c2fc756e6074f918b authored almost 3 years ago by 阿洋 <[email protected]>

Fix "Kubernetes Pod Template" cannot be edited in the job edit page (#568)

d1b4dd0bb59272f98f8222b7165c4a6bd00eecd5 authored almost 3 years ago by 阿洋 <[email protected]>

Merge pull request #561 from xinzhuxiansheng/updatev1

make the parameters of Docker-Java configurable

66a23ae2adfcbb6d6035cf05a13a2c601a97227c authored almost 3 years ago by Al-assad <[email protected]>

fix num type

21f16b853a59c6c90762da01272d46b2412f8dc1 authored almost 3 years ago by 阿洋 <[email protected]>

code format

ba9079e5b3ed1461494fda431361b6a40d962a3b authored almost 3 years ago by 阿洋 <[email protected]>

fix bad code

273685401255ebe0c600febe4c37705ed7003a45 authored almost 3 years ago by 阿洋 <[email protected]>

make the parameters of Docker-Java configurable

4c2ef173bfba0b284b9ab920f2135d23ca132e13 authored almost 3 years ago by 阿洋 <[email protected]>

Merge pull request #560 from Al-assad/type-miss-fix

fixbug: missing type definition

5cbc27624f338eaa181ed84f41d5ecfabb9dd765 authored almost 3 years ago by Al-assad <[email protected]>

fixbug: type definition miss

ff6d53991261f5ecbb84fcde708e5658b2fcd168 authored almost 3 years ago by Al-assad <[email protected]>

Merge pull request #554 from Al-assad/unified_conf

433b75551c61155dc4b54c16aa47d5e12cf9df74 authored almost 3 years ago by Al-assad <[email protected]>

Verify the naming rules of kubernetes clusterId (#556)

9cece294d39e12cc5a93316e3836c67f2d56bfb5 authored almost 3 years ago by 阿洋 <[email protected]>

modify flink config key to val

079ae183d5a7ef8d100c990f6d12fdf1bebc0898 authored almost 3 years ago by Al-assad <[email protected]>

fix error icon (#555)

633ff12a766790fec313a8c0c4ed558f4396e43e authored almost 3 years ago by Al-assad <[email protected]>

fix bug: error config key

dc6778fdcc0c64710b80ee6ea2c3f7a99c3ce0f1 authored almost 3 years ago by Al-assad <[email protected]>

Merge branch 'dev' into unified_conf

5a6791467d5a410c4b7ea3cd715079a44363c7a9 authored almost 3 years ago by Al-assad <[email protected]>

merge FlinkConfigKeyConst into ConfigConst

195f5299fe0c64fc481207826a3c0cf67abdf50f authored almost 3 years ago by Al-assad <[email protected]>

refactor DOCKER_IMAGE_NAMESPACE and DEFAULT_MAVEN_REMOTE_URL to CommonConfig

6176cdb838c1240aad01a857cbbd040af7cdfa31 authored almost 3 years ago by Al-assad <[email protected]>

change class type of silentStateJobKeepTrackingSec

57e81e462877b828049818502eab52217695aed3 authored almost 3 years ago by Al-assad <[email protected]>

typo

72e85f22a09e2aa28953b535908105c4b6f3c926 authored almost 3 years ago by Al-assad <[email protected]>

typo

2b57e44ea3e715f2a7f701fac40e10d7045fb930 authored almost 3 years ago by Al-assad <[email protected]>

refactor STREAMX_HADOOP_USER_NAME to CommonConfig

c20bfb354536e95852e4007edf13b18360d3121c authored almost 3 years ago by Al-assad <[email protected]>

refactor STREAMX_WORKSPACE_LOCAL/STREAMX_WORKSPACE_REMOTE to CommonConfig

07c8f09283e08f64c1ee0aaa9456309395cf4732 authored almost 3 years ago by Al-assad <[email protected]>

rename ConfigurationOptions

758249b492cd7dc83ec9110b0a86cb687e457fc8 authored almost 3 years ago by Al-assad <[email protected]>

refactor KUBERNETES_NAMESPACE_DEFAULT_VALUE to K8sFlinkConfig

40f6a26aa1ad1146397a42d7080ab6425c2634a5 authored almost 3 years ago by Al-assad <[email protected]>

refactor K8sFlinkConfig to unified configuration

9e13b3a9093a843b317498b9d28698131b816375 authored almost 3 years ago by Al-assad <[email protected]>

update comments

6514eb81b6b985f223821f2ef7b56fee992f26d1 authored almost 3 years ago by Al-assad <[email protected]>

overwrite spring config into ConfigHub

9dcc818b8f9eea5920a937f348a745c66d3f0f4b authored almost 3 years ago by Al-assad <[email protected]>

add unified configuration container

1481ac192e3df55045dacde24b0df5b3fff8fc7e authored almost 3 years ago by Al-assad <[email protected]>

[fix]flink home update err no err notify (#550)

* [fix]:flink home update err no err notify
Co-authored-by: wangqingrong <[email protected]>

543b2883744578bd9448dba484ea3ecc3a58dbfe authored almost 3 years ago by monrg <[email protected]>

[Improve] packing and reading resource file optimization #543 (#546)

* [Improve]: sql auto complete improve
* [Enhancement] packing and reading resource file optimi...

b0f87c701d9de232d7a28adb90ac552095b9642a authored about 3 years ago by benjobs <[email protected]>

[]packing and reading resource file optimization (#544)

* [Improve]: sql auto complete improve

* [Enhancement] packing and reading resource file opti...

f785a492181742bd5bf308e26d0384fb8d868926 authored about 3 years ago by benjobs <[email protected]>

[Improve]: sql auto complete improve (#541)

e506293a26d1087e543544283224198aa9e762c7 authored about 3 years ago by benjobs <[email protected]>

Separation of Flink task building & runing process (#476)

* typo

* Add building pipeline type enum and status/error case object.

* add pipeline step...

e5e98388ef0305955b5930cb1f3d5231fc277116 authored about 3 years ago by Al-assad <[email protected]>

修复配置flink-history后，任务失败状态同步错误bug (#536)

* /**
修复配置flink-history后，任务失败状态同步错误bug

Co-authore...

8b685b66d3383974d81b0484921dbf06f30ede67 authored about 3 years ago by haoziaigemao <[email protected]>

[Feat-504]: Add sql auto complete. ( https://github.com/streamxhub/streamx/issues/504 ) (#540)

* Feat(pom.xml):Add txt as source file support.

- 代码：
1. 项目打包添加 `.txt` 文件放入到 `conf` 文件中，用于词频...

d944803e8467cc441005f4d15ec24ff55b7a3820 authored about 3 years ago by Whojohn <[email protected]>

[Improve] test code checkstyle improve (#539)

5a5aa1feb018e715b905fe80ce223f54d4772223 authored about 3 years ago by benjobs <[email protected]>

delete the package-lock.json file (#535)

ef03496c6ee45b7c119f8b86274612c0b6f918d5 authored about 3 years ago by 阿洋 <[email protected]>

[Fix-519]: add the soft link checking for flink home. (#519) (#520)

* Update FlinkVersion.scala

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

5cbac24f851c72ff24c26ea9870170d0de69d762 authored about 3 years ago by lvshaokang <[email protected]>

modify the compression-webpack-plugin version (#534)

2cab316fb5cf5c3a715cbc1483576da5dd955e04 authored about 3 years ago by 阿洋 <[email protected]>

[Feature] project build optimization, better support for front-end and back-end packaging (#533)

* [Feature] project build optimization, better support for front-end and back-end packaging #531

edd5f1a8e41cb2a782e8de6d1d9ddc74cc4620a1 authored about 3 years ago by benjobs <[email protected]>

[Feature] project build optimization, better support for front-end and back-end packaging (#532)

* [Feature] project build optimization, better support for front-end and back-end packaging #531

0e05ba8012185996e9f68107a8801692bc0c74d3 authored about 3 years ago by benjobs <[email protected]>

[hotfix] fix wrong branch in github action (#529)

377cc0e5ea66668e36e8de6f1c30977983a5ab86 authored about 3 years ago by leo65535 <[email protected]>

[hotfix] fix scala style error (#528)

0c5668da693e9d3fe5bbebf8eec17c24727d1214 authored about 3 years ago by leo65535 <[email protected]>

add the log error info where get flink client (#527)

* add the log error info where get flink client

* fix checkstyle

30509a84ea4914920ed10c33de2fc905e42cf2b4 authored about 3 years ago by JunZhang <[email protected]>

Merge pull request #475 from Al-assad/lfs-fix-revert

Fix some legacy bugs for LfsOperator

b630ee10ec0dddcdddc7bc8439a5bfae2c3006d5 authored about 3 years ago by Al-assad <[email protected]>

fix the endTime value (#516)

4d9afbb9196b32ef83257bab4144aa5ad455b5bf authored about 3 years ago by 阿洋 <[email protected]>

Support remote hdfs workspace path with scheme or without (#502)

* support hdfs path with scheme and withou scheme,
like hdfs://hadoopcluster/streamx/ or /strea...

9de61cfac24fe7d9460d1d6a7c70d89c060bac1c authored about 3 years ago by JunZhang <[email protected]>

[Enhancement #512] add header check style (#514)

* [WIP] compatible with both flink yarn/k8s modes task submission/termination (#261)

* [featu...

5e81740f65a27acc9ac095aa591df92df01c9911 authored about 3 years ago by wuchunfu <[email protected]>

automatically check parameter when the system start (#513)

* automatically check parameter when the system start

bc027d34ed1274093ebbf0ef1ead295aca39ebfb authored about 3 years ago by benjobs <[email protected]>

Refer to the list request and fix the duration value (#511)

69e8ddccdb300bec628d3998edc01027875133cc authored about 3 years ago by 阿洋 <[email protected]>

checkstyle code format. (#510)

* demo config bug fixed.

* checkstyle code format.

* checksty...

e552dc692237f8e43194c4a05a0fb4fa7de613d2 authored about 3 years ago by benjobs <[email protected]>

[Enhancement #480] add code style framework (#488)

* [WIP] compatible with both flink yarn/k8s modes task submission/termination (#261)

* [featu...

1213220d35fba984f4a104bb0bd2c9863839544a authored about 3 years ago by wuchunfu <[email protected]>

fix Form.validateFields callback does not execute problem (#503)

* fix form custom rule to validateFields

* adjust code format

2049a5564962b9112e68cfd4d6d57a8c0c7ed57b authored about 3 years ago by 阿洋 <[email protected]>

demo config bug fixed. (#498)

5b9e8abf91bbc75d83135673b53f2242df89c747 authored about 3 years ago by benjobs <[email protected]>

edit job bug fixed. (#495)

* [hotfix] add new upload-local-job bug fixed.

* edit job bug fixed.

128af6fc6704289c6bf761f4b9352f74ab0b4223 authored about 3 years ago by benjobs <[email protected]>

[hotfix] add new upload-local-job bug fixed. (#494)

d1f9d19b2eb27fb0aca38ae3338e81fbd955dedd authored about 3 years ago by benjobs <[email protected]>

fix: user add description (#489)

* 修改spy.properties乱码注释

* fix(fixhadoop-user-name not work #449):

* Revert "fix(fixhadoop-u...

8305620f5437e92a8b8e146f0622f86932d2fe52 authored about 3 years ago by monrg <[email protected]>

[hotfix] 1.2.1 ddl sql bug fixed. (#487)

* [hotfix] 1.2.1 ddl sql bug fixed.

ec131660481f89ec3178675678a323e55e0c3e1d authored about 3 years ago by benjobs <[email protected]>

[hotfix] some words misspelled fixed. (#486)

* [hotfix] some words are misspelled.

57bd9a2811fb1083494ae5b1cb46ba8d5a2b7855 authored about 3 years ago by benjobs <[email protected]>

Supports uploading jar type job (#456)

* [hotfix] change readme image URL.

* [Feat] Supports uploading jar type job

* [Bug] no re...

52b957acd8f791c54d0dbd8963cf33ec6978efb6 authored about 3 years ago by benjobs <[email protected]>

fix: Unable to add role (#483)

* 修改spy.properties乱码注释

* fix(fixhadoop-user-name not work #449):

* Revert "fix(fixhadoop-u...

9f6b38f468ec43c756579ada9132245b63544634 authored about 3 years ago by monrg <[email protected]>

fix: enhance robustness of get flink version (#447) (#477)

a6974e914f9eda5ac5dd462dd95ac31a4cfd280f authored about 3 years ago by lvshaokang <[email protected]>

resolve the merge conflicts

b744cf076563b1fb2f8b5b6286818f1e7e8dc8ee authored about 3 years ago by Al-assad <[email protected]>

Merge branch 'main' into lfs-fix

# Conflicts:
# streamx-common/src/main/scala/com/streamxhub/streamx/common/fs/LfsOperator.scala
...

7415171f7a4c21c5d7d5fdfa3ddeaeb9a4d3d4a5 authored about 3 years ago by Al-assad <[email protected]>

add unit cases for copyDir and md5Hex

ec10f3d36e693564cfde35c425821cb9469e3848 authored about 3 years ago by Al-assad <[email protected]>

fix bug of md5

7f68c6baccd79abd1ca1a65c77851ef7248ad6d1 authored about 3 years ago by Al-assad <[email protected]>

unit test for copy file

31887656767a379afd902604b283063617e656b0 authored about 3 years ago by Al-assad <[email protected]>

fix bug of copy file

44875a6e80c0f0e8536c3caf001b6af035632744 authored about 3 years ago by Al-assad <[email protected]>

Automatic Hadoop integration on Flink Kubernetes mode (#401)

* rename LFsOperator to LfsOperator

* additional file system operation method

* Refactor t...

98dd14fa4c74c01725e87a32f025fcf4609a99bc authored about 3 years ago by Al-assad <[email protected]>

fix bug: wrong jar file chosen when building (#473)

b9872f6b2ef1917a7fc80beca6dcc822e0041acb authored about 3 years ago by gitfortian <[email protected]>

unit test for LfsOperator

4a49c01b8a92b86847569c8b1c5060557da71db9 authored about 3 years ago by Al-assad <[email protected]>

unit test for LfsOperator

0ee2ca2f1cd8d9ba8cdf632144b3e023bcbd8833 authored about 3 years ago by Al-assad <[email protected]>

import junit5

f8533692e3f36aa59b0cbf5ff4a979c9cfe814d8 authored about 3 years ago by Al-assad <[email protected]>

[hotfix] fix specified key too long (#465)

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

449b8444b96deed846b17763baba5fbc170d980e authored about 3 years ago by benjobs <[email protected]>

fix compile error

b9ba2f178771cdcab54aefe69e78afdf1d5340fe authored about 3 years ago by Al-assad <[email protected]>

replace return of getSystemHadoopConfDir, getSystemHiveConfDir to Option

85661ed5125befc9165884809dfc790e1baa8276 authored about 3 years ago by Al-assad <[email protected]>

Merge remote-tracking branch 'upstream/main' into k8s-hadoop-integration

# Conflicts:
# streamx-console/streamx-console-webapp/package-lock.json

bfe29bab6d0e1c48b827030fe80730fa6b39382c authored about 3 years ago by Al-assad <[email protected]>

code optimization

5b10a200bcb8b4774d3f465cdea8769a1717becf authored about 3 years ago by Al-assad <[email protected]>

fix （hadoop-user-name not work #449） (#463)

* fix(hadoop-user-name not work #449):

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

2c756a3ef388bad3bfd63a621da4de9a867b8ee7 authored about 3 years ago by monrg <[email protected]>

Ignore package-lock.json (#462)

e041562c0185919ab0a9d4e5d159eae606a2c2ff authored about 3 years ago by leo65535 <[email protected]>

Merge pull request #448 from Al-assad/asl

Keep ASL-2.0 license from Flink source

304ceaf6c7521ab0143a0e5f30355bd2a6c7a296 authored about 3 years ago by Al-assad <[email protected]>

simplify notice

14a672d4c4da2f5f7ca7dffaf12c4100b30db86d authored about 3 years ago by Al-assad <[email protected]>

[hotfix] change readme image URL. (#455)

31e98ebfde969f95a19d5476eadf9efed08f4d9c authored about 3 years ago by benjobs <[email protected]>

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark