github.com/apache/incubator-streampark commits

update readme. (#451)

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

Add Notice including Flink, mybatis-3 and Maven

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

Keep ASL-2.0 license from Flink source

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

Merge branch 'main' into hadoop_integration

# Conflicts:
# streamx-plugin/streamx-flink-packer/pom.xml

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

Merge pull request #446 from Al-assad/update_ver

Update StreamX Project Version to 1.2.1

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

Merge branch 'main' into hadoop_integration

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

Merge branch 'main' into update_ver

# Conflicts:
# script/update_version.py

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

update version to 1.2.1

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

replace with project version

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

fix argv issue

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

Project version batch replacement script (#441)

* update python indent_size

* Project version number batch replacement script

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

read flinkConfTemplate directly from deployed conf dir (#440)

* change copyDir to new method 'download'

* resolve no-catch Execption.change the level of tr...

21f65fc86aa4f1170e3572362f34a63a9ef1bcbf authored about 3 years ago by 王春顺 <[email protected]>

修改spy.properties乱码注释 (#442)

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

349e831c089f8c17efd4e4b82326b7dddf6f920a authored about 3 years ago by monrg <[email protected]>

Project version number batch replacement script

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

update python indent_size

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

修改ddl。不应该写死db name (#434)

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

Merge pull request #431 from Al-assad/maven_ci_up

Update maven package test ci

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

update maven package test ci

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

Merge pull request #430 from Al-assad/maven_ci

Add Maven package test CI

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

add maven package test ci

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

[hotfix]remove "workspace" environment check from the front end. (#429)

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

resolve merge conflict

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

Merge branch 'main' into hadoop_integration

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

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

fix the bug of pulled image name (#428)

* fix image name pull bug

f96882fcc54d220375a4a41e3ec3c0034dcb95b9 authored about 3 years ago by 王春顺 <[email protected]>

HADOOP_USER_NAME configurable support. (#427)

* more explicit exception information

* readme update.

* HADOOP_USER_NAME configurable sup...

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

build project state bug fixed. (#426)

* more explicit exception information
* readme update.
* build project state bug fixed.

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

readme and copyright update (#425)

* more explicit exception information

* readme update.

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

hot fix: oversized image build lag (#424)

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

custom-code job build fatjar improvement(on k8s) (#423)

* custom-code job deploy on k8s bug fixed

* ChildFirstClassLoader java to scala.

* more ...

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

ChildFirstClassLoader java to scala. (#421)

* ChildFirstClassLoader java to scala.

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

more explicit exception information (#420)

* more explicit exception information

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

Format Code (#419)

* format space

* fix the bug -> move dir when backup disHome

0ebd39f0564cc741e8089ae12f5305437772a6ed authored about 3 years ago by 王春顺 <[email protected]>

copyDir lfs srcPath bug fixed (#418)

* change copyDir to new method 'download'

* resolve no-catch Execption.change the level of tr...

27b7b57c4a19e565072368557fbb61b45fbe66ef authored about 3 years ago by 王春顺 <[email protected]>

Temporary building resources recycling for streamx-packer module (#385)

* Resource GC process

* Scheduled flink-packer resource gc task.

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

Merge branch 'main' into hadoop_integration

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

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

lfs bug fixed (#417)

* change copyDir to new method 'download'

* resolve no-catch Execption.change the level of tr...

b83593a1fb542981b1eccd10a23a21efa8680f0c authored about 3 years ago by 王春顺 <[email protected]>

illegal space indentation

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

Merge branch 'main' into hadoop_integration

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

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

support pod template HostAlias completion, preview on ui.

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

support pod template HostAlias completion, preview.

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

Lfs move file bug fixed. (#416)

* Lfs move file bug fixed.

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

webapp.address retrieve (#414)

* webapp address retrieve

* web app address retrieve

Co-authored-by: rongjianmin1 <rongjia...

26229e3f7e07a424706a74e2e7b653b531aa5039 authored about 3 years ago by 荣建民 <[email protected]>

Lfs move file bug fixed. (#415)

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

job backup bug fixed. (#413)

* consume code job on k8s support.

* apache flink job on k8s support.

* kafka source bug f...

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

remove k8sHostAlias field of Application

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

update css

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

lowcase image name

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

support yaml parser enhance of pod template

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

Fix some bugs in special scene (#412)

* change copyDir to new method 'download'

* resolve no-catch Execption.change the level of tr...

fb924601779d0c63010b202a0aa1dd03b8eadd55 authored about 3 years ago by 王春顺 <[email protected]>

support yaml parser for k8s pod template

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

support exclude localhost

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

refactor podtemplate tool

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

support watch docker image build step

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

update Add page

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

webpack-bundle-analyzer support. (#408)

* apache flink job on k8s support.

* kafka source bug fixed.

* shimsproxy getObject opti...

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

typo

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

Replace DockerClient with HackDockerClient.

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

Hacking DockerClient to provide listenable callback api.

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

[Improve] - optimize shims getObject... (#407)

* kafka source bug fixed.

* shimsproxy getObject optimization

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

[Improve] keep user sql origin line number (#406)

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

b9bf0008a4f934f153196af1a21f9cb7d9d6cdfb authored about 3 years ago by Jake Xie <[email protected]>

[hotfix] - resolve the sql parse conflict (#403)

* [hotfix] - resolve the sql parse conflict

* scala dependencies exclude

* remove unnecess...

f20ebca1f6ec52610182c225fba313ff253a67b7 authored about 3 years ago by Jake Xie <[email protected]>

kafka source bug fixed. (#402)

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

fix bug of matching line that contains host string

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

silent log when delete file that does not exist

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

support view system hadoop config.

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

support choice history of flink-k8s pod-template

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

[Improve] - optimize the sql parse tool (#400)

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

be96ca93d60396a5f4171b2b0caf5695a3c649c4 authored about 3 years ago by Jake Xie <[email protected]>

consume code job on k8s support. (#397)

* apache flink job on k8s support.

* consume code job on k8s support.

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

support search history config of k8sNamespace, k8sSessionClusterId, flinkImage

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

add flink app history search api

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

Support Flink App Conf History Search.

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

Refactor flink app history info method to new Controller and Service.

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

support list upload jars history.

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

support flink k8s-hadoop integration on application mode.

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

support flink k8s-hadoop integration on application mode.

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

fixbug: fail to pull flink base image from dockerhub

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

add hadoop configuration utils.

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

remove unnecessary code

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

Refactor FlinkDockerfileTemplate

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

Refactor the building process of fat-jar and dockerfile of flink-k8s application mode.

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

fix bug of LfsOperator.copy method

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

Offer hosts info tools and replace host of hadoop conf method.

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

rename LFsOperator to LfsOperator

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

additional file system operation method

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

Replace unsuitable constructor injections and format code (#396)

* replace constructor injection

* format author comments.

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

Restrict jobname (#390)

* add jobName check to avoid docker build and rest api remote failed

* change name

* fix M...

81c320a3fec2f849790c7c3f7df0015e92be5a7e authored about 3 years ago by 王春顺 <[email protected]>

flink on yarn job status bug fixed. (#394)

* flink on yarn job status bug fixed #391

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

fix: ChildFirstClassLoader filterResource (#393)

d9da5fcd6365107d7099e52885c482fe5bc8fdc7 authored about 3 years ago by Zclhlmgqzc <[email protected]>

clean up maven dependencies,flink multiple versions classloader bug fixed. (#389)

1. clean up maven dependencies
2. flink multiple versions classloader bug fixed.
3. flinkEnv a...

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

feat: flink 1.14 support (#379)

* feat: flink 1.14 support

* refactor: rename

24ea6fb09ad63ef0b99f218c43a44a53d8ff85fd authored about 3 years ago by Zclhlmgqzc <[email protected]>

bug fix: Check the parameter array before fetching the sql parameter list (#382)

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

a82077e8f9d8bd2bd939d6932548fbdb3d7dbade authored about 3 years ago by Jake Xie <[email protected]>

bug fix: resolve SqlCommand converter NullPointException (#384)

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

7773f1be59252035ff07e601564eb31f2a7b7d3d authored about 3 years ago by Jake Xie <[email protected]>

Merge pull request #372 from Zclhlmgqzc/patch-4

fix: buildFlinkImage pullImageCmd

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

Merge pull request #378 from Al-assad/flink-session-cl

Resolve multiple version isolation issues during Flink session job submission

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

Rename the flink fat-jar file to "streamx-flink_<jobname>" for better discernment

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

add short datetime formatter

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

streamx.sh get pid bug fixed. (#380)

* streamx.sh provided more operations
* streamx.sh get pid bug fixed.

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

Not mandatory to define the hadoop_home env variable at boot.

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

Merge branch 'main-up' into flink-session-cl

# Conflicts:
# streamx-console/streamx-console-service/src/assembly/bin/startup.sh

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

Not mandatory to define the hadoop_home env variable at boot.

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

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark