github.com/apache/incubator-streampark issues

[Bug] Flink job modified time change with duration

SusubingYi opened this issue over 1 year ago

[Improve] Authentication code optimization

ChengJie1053 opened this pull request over 1 year ago

[Feature][Flink-K8s-V2] Add KubernetesApplicationClient.shutdown on Flink-Kubernetes-V2

caicancai opened this pull request over 1 year ago

[Feature] Add Kubernetes native application client.shutdown on Flink-Kubernetes-V2

caicancai opened this pull request over 1 year ago

[Feature] [Flink-K8s-V2] Refactor the lifecycle control code of Flink clusters on Kubernetes

caicancai opened this pull request over 1 year ago

[Improve] GitUtils code optimization

ChengJie1053 opened this pull request over 1 year ago

[Improve] Enumeration improvement

wolfboys opened this pull request over 1 year ago

[Improve] Unified Naming Rules for Enumeration Classes

xsymin opened this pull request over 1 year ago

Refactor the lifecycle control code of flink clusters on kubernetes

caicancai opened this pull request over 1 year ago

[Improve] Unified Naming Rules for Enumeration Classes (#3133)

xsymin opened this pull request over 1 year ago

Dev enum

xsymin opened this pull request over 1 year ago

[Improve] Improve streampark-flink-client-core module base on [Naming Style]

caicancai opened this pull request over 1 year ago

[Fix] Modify the isPythonFileType parameter

ChengJie1053 opened this pull request over 1 year ago

[Improve] Unified Naming Rules for Enumeration Classes (#3133)

xsymin opened this pull request over 1 year ago

[Improve] Improve streampark-common module base on [3.9 Java Streams]

VampireAchao opened this pull request over 1 year ago

[Improve] optimize enum RestoreMode getName function

VampireAchao opened this pull request over 1 year ago

[Improve] Streampark-common module tika dependency moved to the streampark-console module

ChengJie1053 opened this pull request over 1 year ago

[Improve] package name improvement

wolfboys opened this pull request over 1 year ago

[WIP][Feature] Support Flink 1.18 application submit

ChengJie1053 opened this pull request over 1 year ago

[Improve] alerm minor improvement

wolfboys opened this pull request over 1 year ago

在构建application时，提示权限不对，在本地已经试验过可以用docker pull拉取自定义的flink镜像的，不知道是哪里出了问题？我的镜像仓库是sealer默认的镜像库，本地手工执行docker pull flink1.17.1没问题。该镜像库没有设置auth，所以没有用户名和口令。

fi-ecavc opened this issue over 1 year ago

[Feature] Support Flink 1.18

wolfboys opened this issue over 1 year ago

[Fix] Fix the issue of Scala calling Mybatis LambdaWrapper with Java function reference

Al-assad opened this pull request over 1 year ago

[Improve] [Flink-K8s-V2]improve code style

caicancai opened this pull request over 1 year ago

streampark webui can not fresh（streampark 网页不能刷新）

sunshanggege opened this issue over 1 year ago

[Feature] Improve the blog module of incubator-streampark-website

caicancai opened this issue over 1 year ago

[Feature] Add application backup clean task

GOODBOY008 opened this pull request over 1 year ago

[Bug] application mode start flink job. provided.lib.dirs error

king-sjr-007 opened this issue over 1 year ago

sreampark do not support sealos image repo

fi-ecavc opened this issue over 1 year ago

[Fix-3153] Alert information cannot be sent in cancelling state

SbloodyS opened this pull request over 1 year ago

[Improve] improve README.md

caicancai opened this pull request over 1 year ago

[Bug] npm ps vulnerability CVE-2022-24999

littlefishermen opened this issue over 1 year ago

[Fix] Interceptors add /resource/upload

ChengJie1053 opened this pull request over 1 year ago

[Bug] Alert information cannot be sent in cancelling state

SbloodyS opened this issue over 1 year ago

[Improve] Add additional use cases for FlinkOperator on Kubernetes

caicancai opened this pull request over 1 year ago

[Improve] Improve assembly.xml baseDirectory name

liuenci opened this pull request over 1 year ago

[Improve] FlinkAppHttpWatcher improvement

wolfboys opened this pull request over 1 year ago

[Improve] Unified Naming Rules for Enumeration Classes (#3133)

xsymin opened this pull request over 1 year ago

[improve] add how to Contribute

caicancai opened this pull request over 1 year ago

[Feature] Improve K8S documentation

caicancai opened this issue over 1 year ago

[Feature] add contributor documentation to README

caicancai opened this issue over 1 year ago

[Feature] Sql parser support jar statements and analyze statements

ChengJie1053 opened this pull request over 1 year ago

[Bug] The incorrect for loop writing method resulted in the same valu…

wangkeshuai1 opened this pull request over 1 year ago

[ISSUE-3142][Improve] Extract the exception utils methods into ExceptionUtils.

RocMarshal opened this pull request over 1 year ago

[Improve] Extract the exception utils methods into ExceptionUtils.

RocMarshal opened this issue over 1 year ago

[Improve] Shims base module code optimization

ChengJie1053 opened this pull request over 1 year ago

[Cleanup] Remove the package org.apache.streampark.common.tuple of streampark-common module. #3132

ligenhw opened this pull request over 1 year ago

[Bug] Streampark flink Application status is in inconsistent with Flink web ui.

jkl0898 opened this issue over 1 year ago

[Cleanup] Remove the redundant Serializable implementation for all En…

ligenhw opened this pull request over 1 year ago

[Improve] Unified enumeration comparison methods

Xuxiaotuan opened this pull request over 1 year ago

[Improve] Modify savepoint parameter name

ChengJie1053 opened this pull request over 1 year ago

[Improve] Unified Naming Rules for Enumeration Classes

wuchunfu opened this issue over 1 year ago

[Cleanup] Remove the package `org.apache.streampark.common.tuple` of `streampark-common` module.

RocMarshal opened this issue over 1 year ago

[Cleanup] Remove the redundant `Serializable` implementation for all Enums of the project.

RocMarshal opened this issue over 1 year ago

[Improve] Improve streampark-common module base on 3.1 Naming Style

Kick156 opened this pull request over 1 year ago

[Improve] Unified enumeration comparison methods

wuchunfu opened this issue over 1 year ago

[Improve] application state improvement

wolfboys opened this pull request over 1 year ago

[Improve] project page improvement

wolfboys opened this pull request over 1 year ago

[Improve][All] Improvement of StringUtils.isEmpty method

wuchunfu opened this pull request over 1 year ago

[Improve] project clone openssh higher version improvement

wolfboys opened this pull request over 1 year ago

[Feature] Flink remote support pyflink maven dependency

ChengJie1053 opened this pull request over 1 year ago

fix: app create err & fix type error

wangsizhu0504 opened this pull request over 1 year ago

[Improve] RestResponse fail method improvement

wolfboys opened this pull request over 1 year ago

[Improve] Improve streampark-console module base on [3.2 Constant Variables Definition]

wuchunfu opened this pull request over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [6 Testing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [5 Log]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [4 Exception Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.10 Pre-Conditions Checking]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.9 Java Streams]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.8 Java Lambdas]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.7 Code Comments Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.6 Control/Condition Statements]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.5 Concurrent Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.4 Collection Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.3 Methods Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-test-utils` module based on [3.2 Constant Variables Definition]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-testcontainer` module based on [3.1 Naming Style]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.10 Pre-Conditions Checking]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [6 Testing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [5 Log]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [4 Exception Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.9 Java Streams]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.8 Java Lambdas]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.7 Code Comments Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.6 Control/Condition Statements]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.5 Concurrent Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.4 Collection Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.3 Methods Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.2 Constant Variables Definition]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-spark` module based on [3.1 Naming Style]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [6 Testing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [5 Log]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [4 Exception Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.10 Pre-Conditions Checking]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.9 Java Streams]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.8 Java Lambdas]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.7 Code Comments Rule]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.6 Control/Condition Statements]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.5 Concurrent Processing]

RocMarshal opened this issue over 1 year ago

[Improve] Improve `streampark-flink` module based on [3.4 Collection Rule]

RocMarshal opened this issue over 1 year ago

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark