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

Modify the flink session job submission solution to be via the rest api.

ce5bf3abccbe02ae1ccf845a6279ae43d0ec1699 authored about 3 years ago by Al-assad <[email protected]>
public retrieving flink jobmanager rest api method.

b962248edd86b764241dc98e8b7d631c1c363722 authored about 3 years ago by Al-assad <[email protected]>
flink shims classloader and relevant cache.

dfdb853f0828e9799b654c371d082fa24f10d42a authored about 3 years ago by Al-assad <[email protected]>
move to tool package

9049c686baaa34aebb5776d862fa98f92c12ff85 authored about 3 years ago by Al-assad <[email protected]>
maven wrapper provided (#377)

* readme update.

* maven wrapper provided

* streamx.sh provided more operations

e0fad5dcb638e1cff2eeee27dd0fe697f5e3f9d3 authored about 3 years ago by benjobs <[email protected]>
update to junit5

68a0d2d07c543cee5c8c959b87164da35796e79e authored about 3 years ago by Al-assad <[email protected]>
Remove repetitive dependency

0a9c16c9679215e27a7c28432b3e13d4fee0eaa5 authored about 3 years ago by Al-assad <[email protected]>
bug fix: explain statement does't work due to incorrect sql parameters (#375)

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

45f6c45b45e1629c17878332fd8cd370c1da28fa authored about 3 years ago by Jake Xie <[email protected]>
project build statue bug fixed (#376)

project build statue bug fixed

What's Changed:

1. project build statue bug fixed.
2. sy...

54ebf87c1bb51786668b3622883aa9fdbc4fd102 authored about 3 years ago by benjobs <[email protected]>
Unified flink version to 1.13

b317e1c76931d8b3c1fe0badb2d6c1e50ee9c66a authored about 3 years ago by Al-assad <[email protected]>
check environment bug fixed. (#373)

1. in the on yarn mode, before deploy a job( publishing to hdfs), initialize the environment(f...

2723b24973019fed12eb4551ede1555a8feddb9b authored about 3 years ago by benjobs <[email protected]>
fix: buildFlinkImage pullImageCmd

2aae96180f3b9738eea948a6a301bd468db1f437 authored about 3 years ago by Zclhlmgqzc <[email protected]>
apphome bug fixed(on yarn|k8s) (#370)

* remove shims jar from startup.sh

* apphome bug fixed(on yarn|k8s)

06ef9410d76da84f046883fd589d1f7b51ccbbfb authored about 3 years ago by benjobs <[email protected]>
SqlDialect bug(#364) (#365)

* SqlDialect bug

* Fix SqlDialect bug, Throw exception when dialect is not valid

684eb9ab8ef0b3f8c2de0721c9478a92107515d8 authored about 3 years ago by carl cao <[email protected]>
Failed to load flink-shims during flink sql verify (#357) (#366)

* Separate the docker image pull and build process

* lost flink versionId when verifying sql....

1f62ecc294cdc3747e5ec8a3f83eefcefc138068 authored about 3 years ago by Al-assad <[email protected]>
Separate the docker image pull and build process (#363)

659d7f635f5ddc5c113f389cb8a0588e0ad6b6a4 authored about 3 years ago by Al-assad <[email protected]>
Merge pull request #361 from Zclhlmgqzc/patch-2

fix: import ServicesResourceTransformer

f098989d59f31a3e49fe8ad9026094b90441e744 authored about 3 years ago by Al-assad <[email protected]>
fix: import ServicesResourceTransformer

21d0642f72ed369d8a8436326a184d2c7a33caaf authored about 3 years ago by Zclhlmgqzc <[email protected]>
Merge pull request #359 from Zclhlmgqzc/patch-1

ecf1e9ccc4c7a2ef0d1bc77ea2dec11890fbfd6d authored about 3 years ago by Al-assad <[email protected]>
Update placeholder content of "Rest-Service Exposed Type" (#358)

db880cd948c28bf29b33e9403433abe714e93132 authored about 3 years ago by Al-assad <[email protected]>
flink 1.14 support (#360)

* flink 1.14 support,multily version runtime dependency isolation

4c80e13643a73697ee131e49e956966758f08c78 authored about 3 years ago by benjobs <[email protected]>
fix: transform table connectorformat resources

63c502d3a0c1f8d472de4c37725647aa1dda0533 authored about 3 years ago by Zclhlmgqzc <[email protected]>
flink 1.14 support (#356)

* flink 1.14 support (#353)

* refactoring workspace logic,better adaptive local package build...

0514ad2b3cadd86d6469d90f914dc24de19df2d5 authored about 3 years ago by benjobs <[email protected]>
fix: commandUtils execute on windows (#351)

e2cb3b829c19a6fa3f2ddc880e2bf19da22aa092 authored about 3 years ago by Zclhlmgqzc <[email protected]>
fix: outFatJarPath should be a file (#352)

* fix: outFatJarPath should be a file

* Update MavenTool.scala

1203a9055f240ec48d5df1f18fdbca2fe17e78ab authored about 3 years ago by Zclhlmgqzc <[email protected]>
[Feature] flink 1.14 support. (#350)

* [Feature]flink 1.14 support.

ff40bcc8c38eaeae3a159b51d3ca3d9014a7beb7 authored about 3 years ago by benjobs <[email protected]>
workspace optimization,spelling correction of some words (#347)

workspace optimization,spelling correction of some words

c8f502abfe3ac16f7b0dd7407897286e960126fc authored about 3 years ago by benjobs <[email protected]>
Merge pull request #344 from SoberChina/fix-perjob

f53543d06ad46f792a3a7ce13348007e12376a48 authored about 3 years ago by Al-assad <[email protected]>
fix per-job for fromSavepoint

48b6b8c5676ac462cc9803bd569fcd9840dcccba authored about 3 years ago by liweigao <[email protected]>
fix per-job for fromSavepoint

dbbb13a012b0029102998a5f8f7ce67b72b9414d authored about 3 years ago by liweigao <[email protected]>
fix per-job for fromSavepoint

a6700f43bac42255b121c8b81ab8654444630b0c authored about 3 years ago by liweigao <[email protected]>
workspace optimization,spelling correction of some words (#335)

* workspace optimization,spelling correction of some words

164eb42e4ecf8f879ab1c296fa49983fbc9e2fe7 authored about 3 years ago by benjobs <[email protected]>
refactoring workspace logic,better adaptive local package build, on yarn and on k8s (#332)

* refactoring workspace logic,better adaptive local package build, on yarn and on k8s
* new cla...

a53a054d60799142432a260c8532b44b62c3a163 authored about 3 years ago by benjobs <[email protected]>
Merge pull request #331 from streamxhub/feature-k8s

Provide Flink-K8s Runtime Support for StreamX

be4cb1be86f825d257f7593fef6b9d37a088498f authored about 3 years ago by al-assad <[email protected]>
Merge branch 'main' into feature-k8s

5bba9396f1d4c5f00bf9674a2e2a1db3a58044f3 authored about 3 years ago by benjobs <[email protected]>
Update streamx version to 1.2.0 (#329)

Update streamx version to 1.2.0

d928f1cef1e90b4d2a763658029d568af96f1987 authored about 3 years ago by al-assad <[email protected]>
character logo change (#328)

* move document.

* character logo change.

1c2c76c0d9a4de85b1f9a67ef914e2560b619402 authored about 3 years ago by benjobs <[email protected]>
Fix the UI misalignment problem of Add.vue page (#326)

Fix the UI misalignment problem of Add.vue page

9df6b2e504243282b6bd398f71adcb3304c573f4 authored about 3 years ago by al-assad <[email protected]>
[WIP] Phase support for Flink-K8s runtime (#320)

* fix bug: streamx.console.workspace setting missing

* remove refilling setting process

* ...

c22c1c3c8554d87d6d1e6a3436ae533a6d8862e5 authored about 3 years ago by al-assad <[email protected]>
Update V1_1_2__upgrade_db.sql (#321)

* Update V1_1_2__upgrade_db.sql

脚本错误，该bug导致数据库字段错误，程序启动异常。

* Update V1_1_2__upgrade_db.sql...

a4fac3b063c9c964e7076c99754d7bfa6053b923 authored about 3 years ago by ck <[email protected]>
Feature k8s (#315)

* StreamX documentation!

* streamx documentation

* streamx documentation

* streamx docu...

5019da813adc4028159237aac97e0c7a00c94eda authored over 3 years ago by benjobs <[email protected]>
StreamX documentation! (#314)

014a92b7d2791465e8cb95bfec3be1ed32f686a5 authored over 3 years ago by benjobs <[email protected]>
KafkaSource add charset

abdf5d43e7fc8419056d9e03d0f7bfacfeb6456d authored over 3 years ago by benjobs <[email protected]>
jar file verify bug fixed. (#304)

* [hotfix]jar file verify bug fixed.

* [hotfix]jar file verify bug fixed.

* [hotfix]jar fi...

255a0c9bcdfd5cbb2ecc832ff260176486a6a3fe authored over 3 years ago by benjobs <[email protected]>
[hotfix] jar file verify bug fixed (#303)

* [hotfix]jar file verify bug fixed.

* [hotfix]jar file verify bug fixed.

d345f2017cd69aeb656a78b5ef1f69ebc8ed82c7 authored over 3 years ago by benjobs <[email protected]>
[WIP]Multi version flick support (#296)

* metrics & status tracking support for flink-k8s-mode

* [WIP]Multi version flick support

...

b25e5be74f4fd830f8160bae0d40ae1b414164b1 authored over 3 years ago by benjobs <[email protected]>
metrics & status tracking support for flink-k8s-mode (#295)

6e42a29b299779e8da829e47be033b859b9988a5 authored over 3 years ago by benjobs <[email protected]>
[WIP] metrics & status tracking support for flink-k8s-mode (#294)

* fix bug: streamx.console.workspace setting missing

* remove refilling setting process

* ...

e88966b2d748b0ee8f4af95abcea0a7a2a4edb5b authored over 3 years ago by al-assad <[email protected]>
streamx-console: add new parameter "k8sNamespace" (#291)

68e2ee79aefa9406b0a4be9eef245c7828234500 authored over 3 years ago by benjobs <[email protected]>
streamx-console: k8s adaptation bug fix (#290)

* update unit test

* fix bug: streamx.console.workspace setting missing

* force create loc...

d1c507d60a506ff311f77053b04710bc71c3565b authored over 3 years ago by al-assad <[email protected]>
Using cache to speed up build fatjar (#287)

* Using cache to speed up build fatjar

e6d6017ab965d1e9feee4ca21a59418b7b9b6dc8 authored over 3 years ago by benjobs <[email protected]>
[Feature] streamx-console/streamx-console-webapp provide additional GUI adaptations for flink k8s mode (#286)

* [Feature] streamx-console/streamx-console-webapp provide additional GUI adaptations for flink ...

65243304117f84f8217f46a05c85b55a1a61f4e3 authored over 3 years ago by benjobs <[email protected]>
[hotfix] file upload request parameters bug fixed. (#285)

16fee3a9d4e66530b533d2ab612bb5310b6fa15b authored over 3 years ago by benjobs <[email protected]>
Feature k8s (#283)

* [optimize] streamx-packer rename to streamx-flink-packer #249

* [Feature] streamx-console/s...

87b18fa09fe814b069931d9eb3f43796cfae8164 authored over 3 years ago by benjobs <[email protected]>
Update FUNDING.yml

e8b38136e56a76d315b489010ff079d8698ab4a9 authored over 3 years ago by benjobs <[email protected]>
Update FUNDING.yml

e0dfe41dbe7d2268f3c7bf115f99f771bc560e7a authored over 3 years ago by benjobs <[email protected]>
Update FUNDING.yml

bb64f6e6d1757199be8ab92677a9dcf057484084 authored over 3 years ago by benjobs <[email protected]>
Update FUNDING.yml

559fbd3bafe0520ee1de2a93e496d718a67b654e authored over 3 years ago by benjobs <[email protected]>
Update FUNDING.yml

b2be5e1ecadd5b0af45d0c7fbbcdcde88347abf8 authored over 3 years ago by benjobs <[email protected]>
Create FUNDING.yml

90daee9cea54230b2a242a58ba2019b91b2745ba authored over 3 years ago by benjobs <[email protected]>
[optimize] streamx-packer rename to streamx-flink-packer #249 (#282)

aecafa608ecc27d59e1f0e78de45f3e0196fdb62 authored over 3 years ago by benjobs <[email protected]>
[Feature] storage auto adaptation #259 (#279)

* [optimize] streamx-codebuild rename to streamx-packer #249

* [Feature] storage auto adaptat...

421129f33e8ab5ab0dc773e4bc01ae224305e281 authored over 3 years ago by benjobs <[email protected]>
[optimize] streamx-codebuild rename to streamx-packer #249 (#278)

e8c71b45bf1f7c3de74d0b86b892a253500c1daa authored over 3 years ago by benjobs <[email protected]>
support build flink image in k8s-native application mode #249 (#277)

* add .gitignore

* build fat-jar when submit flink k8s-session job

* remove gitkeep

* c...

25964255c5ec11b32607f677a2a59c928ee52c6d authored over 3 years ago by al-assad <[email protected]>
Add unit tests for DockerTool (#276)

* add .gitignore

* build fat-jar when submit flink k8s-session job

* remove gitkeep

* c...

bb70fa3b18eb038e71044045e71c3708e488de17 authored over 3 years ago by al-assad <[email protected]>
[bugfix] create TEMPORARY view bug fixed #273 (#275)

* [bugfix] flinkSql verify bug #265

* [bugfix] create TEMPORARY view bug fixed #273

711971fbea1042f9345529b9d2e600a81477e693 authored over 3 years ago by benjobs <[email protected]>
Add Docker Image Build Tools (#272)

* add .gitignore

* build fat-jar when submit flink k8s-session job

* remove gitkeep

* c...

882642b08f084279de7460df603d935725ef5135 authored over 3 years ago by al-assad <[email protected]>
build fat-jar before submitting flink job on k8s-session mode (#271)

* add .gitignore

* build fat-jar when submit flink k8s-session job

4cc41f6de82ad88477fdd7366824b9dba152ee05 authored over 3 years ago by al-assad <[email protected]>
Import scalatest and add unit test for MavenTool (#270)

* modify configuration constants of workspace(#251)

* typo(#251)

* add isAnyBank method(#2...

ae86c5359e649420e706677c2cf4aa959a469080 authored over 3 years ago by al-assad <[email protected]>
sync feature-k8s from main (#269)

* [bugfix] flinkSql verify bug fixed (#244)

[bugfix] flinkSql verify bug fixed.

* Update ...

55ee9f4ff999384b3f8eba54a9301f5b3a91c297 authored over 3 years ago by al-assad <[email protected]>
[bugfix] flinkSql verify bug #265 (#268)

41315246314e4e61820e6f6608ba5d8a74e853b1 authored over 3 years ago by benjobs <[email protected]>
add maven/docker dynamic build module (#263)

* modify configuration constants of workspace(#251)

* typo(#251)

* add isAnyBank method(#2...

2581f0a9597a4837d7c9f0b1d1d8c597ae560f8a authored over 3 years ago by al-assad <[email protected]>
[feature] storage auto adaptation(HDFS|LFS) (#260)

* Storage auto adaptation #259

4e075261b5de4006f1b9a998c624f2f6b58a2e65 authored over 3 years ago by benjobs <[email protected]>
Workspace storage compatibility for HDFS and LFS (#253) (#258)

Workspace storage compatibility for HDFS and LFS (#253)

81366635693fda06f809ff840670f9590b04a469 authored over 3 years ago by benjobs <[email protected]>
Workspace storage compatibility for HDFS and LFS (#253)

* modify configuration constants of workspace(#251)

* typo(#251)

* add isAnyBank method(#2...

1dce1efd07777dfb2d810356b18311e2ffe3da42 authored over 3 years ago by al-assad <[email protected]>
"create temporary table..." syntax parse bug fixed (#257)

* [bugfix] flinkSql verify bug fixed.

* [feature]SqlConvertUtils format sql support.

* [24...

87022d204ba342b7bfd9ed2a33f345204e8bbd97 authored over 3 years ago by benjobs <[email protected]>
[bugfix] KafkaSource topic no matching type when parsing (#254)

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

6d6b69df12f61246452a6bbb5c52fcc24d04c156 authored over 3 years ago by 1353297670 <[email protected]>
Merge pull request #221 from Al-assad/feature-k8s-flink

flink k8s-native support task of #247 #248

09ded3888562098543011100d647dadcb57de909 authored over 3 years ago by al-assad <[email protected]>
Merge branch 'main' into feature-k8s-flink

# Conflicts:
# streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/s...

f9a28da6edacac68c88817896dce5be955d9b231 authored over 3 years ago by Al-assad <[email protected]>
Update github issue and pr template (#245)

* .github: update issue template

* .github: add chinese issue template

* .github: add defa...

c3a5f98a8cb939bdccd513044ecf576b7047f579 authored over 3 years ago by al-assad <[email protected]>
[bugfix] flinkSql verify bug fixed (#244)

[bugfix] flinkSql verify bug fixed.

02293a61351dc30bfb253df3ce6d0a44a79f7f48 authored over 3 years ago by benjobs <[email protected]>
Update LICENSE

60e67ed43644f2334160132134950fb1ca80cd1d authored over 3 years ago by benjobs <[email protected]>
release 1.1.1

* 1.1.1 release

* 1.1.1 release

* 1.1.1 release

5cd7f5c2f4c19e71e89eee4210b7cc0f5bb08718 authored over 3 years ago by benjobs <[email protected]>
[issue#220] refactor: move the parameters of the flink stop method to a dedicated dto object

5daec13807b8ef1113114562049a311609c38545 authored over 3 years ago by yulinying <[email protected]>
[issue#220] New dto object for flink stop action parameter transfer process

f8645b23a54dcdf8c4c9c996ce9f9bbede006a7a authored over 3 years ago by yulinying <[email protected]>
Merge remote-tracking branch 'origin/feature-k8s-flink' into feature-k8s-flink

# Conflicts:
# streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/s...

f36224933f6e4672912183175ed76f7ccdfe573e authored over 3 years ago by yulinying <[email protected]>
[issue#220] refactoring SubmitRequest, SubmitResponse to adapt k8s submit operations

26857eef18fa5b88195bb853b4daa8377dba2bcb authored over 3 years ago by yulinying <[email protected]>
[issue#220] refactoring SubmitRequest, SubmitResponse to adapt k8s submit operations

df9d6d68de0ab49e3eb2168547dc653c5b56242d authored over 3 years ago by yulinying <[email protected]>
Merge pull request #223 from wolfboys/main

[bugfix]kerberos relogin bug fixed.

8cf430e05ea6a8b7021de08536969aa02c8c9ac5 authored over 3 years ago by benjobs <[email protected]>
[bugfix]kerberos relogin bug fixed.

96afdad950ce96bd122dde1bb9c6a6cd2c6ead2b authored over 3 years ago by benjobs <[email protected]>
Merge pull request #222 from CecilHarvey/main

fix bug: all records in app table may be overwritten during deploy under some conditions

38e79859deddea20ce8118b3d79d16135ae0c876 authored over 3 years ago by benjobs <[email protected]>
fix bug: all records in app table may be overwritten under some conditions.

4555f2ed4e152bf998a9d6ad67c981341a811bbb authored over 3 years ago by Wei Mingzhi <[email protected]>
[feature] flink k8s native mode support

288464f22ca69916b1b27b5e667827c4118767e8 authored over 3 years ago by yulinying <[email protected]>
[feature] flink k8s native mode support

da6fb95e007eda5874632efe2ab8a053f4f6ce34 authored over 3 years ago by yulinying <[email protected]>
Update LICENSE

78fa06b75e0440ffa2904e16f069b46ba023d812 authored over 3 years ago by benjobs <[email protected]>
Update LICENSE

574a84e15a1756b7d9ae356de7a014d80a8bcf9b authored over 3 years ago by benjobs <[email protected]>
Merge pull request #217 from wolfboys/main

Create LICENSE

4df6c453ece3e091d3181d4545069d3d62c7a719 authored over 3 years ago by benjobs <[email protected]>
Create LICENSE

a5c4e1fe7c86b99c80d92ad1278fdaaafae97f5a authored over 3 years ago by benjobs <[email protected]>
Merge pull request #216 from wolfboys/main

license added.

e9b7d6ace823e90505c90ee197a360ce1fa0f337 authored over 3 years ago by benjobs <[email protected]>
license added.

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