github.com/apache/incubator-streampark issues

remove scala2.11

caicancai opened this pull request over 1 year ago

[Improve] FileUtils minor improvement

wolfboys opened this pull request over 1 year ago

[Refactor] Remove LogClientService and minor code refactor

GOODBOY008 opened this pull request over 1 year ago

[Bug] Flink job batchMode bug fixed

wolfboys opened this pull request over 1 year ago

[Improve] scala version in module names improvement

wolfboys opened this pull request over 1 year ago

[Bug] Version 2.1 Submitting a batch task is abnormal

Dkbei opened this issue over 1 year ago

Flink k8s v2

caicancai opened this pull request over 1 year ago

[Improve] Remove Scala version in module name.

wolfboys opened this pull request over 1 year ago

Fix remote task submission could not find the jar

ChengJie1053 opened this pull request over 1 year ago

[Improve] settings improvement

wolfboys opened this pull request over 1 year ago

[Improve] restore mode minor improvement

wolfboys opened this pull request over 1 year ago

Supports specifying config file when creating KubernetesClient

ChengJie1053 opened this pull request over 1 year ago

[Refactor] Refactor Setting and fix code style

GOODBOY008 opened this pull request over 1 year ago

flink都不用scala了，这个项目还是scala，快用java重构吧

Cqz666 opened this issue over 1 year ago

[Bug] flink sql sink mysql error

zhugezifang opened this issue over 1 year ago

Added flink k8s operator validate

ChengJie1053 opened this pull request over 1 year ago

[Refactor] Refactor multiple enum classes and update related methods to be more readable

GOODBOY008 opened this pull request over 1 year ago

minor codestyle improvement

wolfboys opened this pull request over 1 year ago

[Bug]resource_path is not exist in ResourceMapper

zhugezifang opened this issue over 1 year ago

[Proposal] Upgrade Java version to 11

Al-assad opened this issue over 1 year ago

[Bug] An error is reported when the source code is compiled

caicancai opened this issue over 1 year ago

License header improvement

wolfboys opened this pull request over 1 year ago

[type:fix] Refactor AlertType class for fix cannot trigger alert

GOODBOY008 opened this pull request over 1 year ago

module improvement

wolfboys opened this pull request over 1 year ago

[Feature] Yarn supports pyflink

ChengJie1053 opened this pull request over 1 year ago

[Polish] Fix error msg typo

GOODBOY008 opened this pull request over 1 year ago

add pprint dependency

caicancai opened this pull request over 1 year ago

docker push improvement

wolfboys opened this pull request over 1 year ago

[Feature] Force a rebuild of the flink job's image for including the latest base image change

Nivane opened this issue over 1 year ago

[Bug] Flink Batch Mode Wrong Status On K8s

Nivane opened this issue over 1 year ago

[Bug] The main method caused an error: UpsertStreamTableSink requires that Table has a full primary keys if it is updated.

kiritozhan opened this issue over 1 year ago

jar upload bug fix

ChengJie1053 opened this pull request over 1 year ago

fix: FE build script

wangsizhu0504 opened this pull request over 1 year ago

docs: drop vanity metrics from README

tisonkun opened this pull request over 1 year ago

[Bug] Build Docker Image CI continuously fails

tisonkun opened this issue over 1 year ago

[Feature] StreamPark Autonomous Health Probing

xujiangfeng001 opened this issue over 1 year ago

ResourceServiceImpl code optimization

ChengJie1053 opened this pull request over 1 year ago

Modify pgsql-schema.sql

ChengJie1053 opened this pull request over 1 year ago

[Proposal] Easy widetable

lysgithub0302 opened this issue over 1 year ago

[Bug] Don't savedown salted password for LDAP login

saLeox opened this issue over 1 year ago

Extract common const FLINK_NATIVE_KUBERNETES_LABEL

ChengJie1053 opened this pull request over 1 year ago

FlinkK8sEventWatcher remove useless code

ChengJie1053 opened this pull request over 1 year ago

[ISSUE-2936][Feature] Support flink native type savepoint

xbthink opened this pull request over 1 year ago

[Feature] Support native format savepoint

xbthink opened this issue over 1 year ago

[Bug] 无法删除flink项目任务

lawrence191 opened this issue over 1 year ago

issue-2753 bug fixed.(#2753)

zhaoningshengg opened this pull request over 1 year ago

streampark-flink-kubernetes-v2 fix test case bug

caicancai opened this pull request over 1 year ago

fix:inserting failure when the values contain 'value'

caogaoshuai opened this pull request over 1 year ago

SinkRequest SQL stitching Bug

caogaoshuai opened this issue over 1 year ago

Configuration table but no table

chenhaonan313 opened this issue over 1 year ago

[Bug] Bug title

chenhaonan313 opened this issue over 1 year ago

[Flink-V2] Restore test resources

Al-assad opened this pull request over 1 year ago

flink on k8s 服务用clusterId。Flink WebUI地址不对。

gaozhan333 opened this issue over 1 year ago

[Improve] flink job restore mode option improvement

wolfboys opened this pull request over 1 year ago

issue-2869 bug fixed.

wolfboys opened this pull request over 1 year ago

menu icon improvement

wolfboys opened this pull request over 1 year ago

dependency minor improvement

wolfboys opened this pull request over 1 year ago

[Optimization] optimization RestResponse

VampireAchao opened this pull request over 1 year ago

ClusterKey code optimization

ChengJie1053 opened this pull request over 1 year ago

[Improvement] avoid errors in batch insert caused by different tables or columns

lenonhere opened this pull request over 1 year ago

[Feature] StreamPark Support Kubernetes 1.24 crictl

mingwayXue opened this issue over 1 year ago

[Feature] [Sql Gateway] Implement flink gateway v2 api

GOODBOY008 opened this issue over 1 year ago

[Flink-K8s-V2] Port the new module codes to Streampark-flink-kubernetes-v2

Al-assad opened this pull request over 1 year ago

[Umbrella] StreamPark code-style-and-quality Improve

RocMarshal opened this issue over 1 year ago

IngressController code optimization

ChengJie1053 opened this pull request over 1 year ago

[optimization] console service code optimization

VampireAchao opened this pull request over 1 year ago

YarnSessionClient code optimization

ChengJie1053 opened this pull request over 1 year ago

[Sql Gateway] Implement flink gateway v2 api

GOODBOY008 opened this pull request over 1 year ago

[Flink-K8s-V2] Create Shaded module for flink-kubernetes-operator-api dependency

Al-assad opened this pull request over 1 year ago

Modify RemoteClient log

ChengJie1053 opened this pull request over 1 year ago

[Bug] Fail to submit a yarn-session job

Dsrong opened this issue over 1 year ago

The YarnClientTrait add clusterClient close

ChengJie1053 opened this pull request over 1 year ago

[Feature] support for flink cluster configuration

xujiangfeng001 opened this pull request over 1 year ago

[Feature] support for flink cluster configuration

xujiangfeng001 opened this issue over 1 year ago

[ISSUE-2902][improvement] improvement flink cluster verifyClusterConnection

xujiangfeng001 opened this pull request over 1 year ago

[improvement] improvement flink cluster verifyClusterConnection

xujiangfeng001 opened this issue over 1 year ago

[Bug] fail to submit a yarn-session task

Dsrong opened this issue over 1 year ago

[Bug] fail to submit a yarn-session task

Dsrong opened this issue over 1 year ago

[Bug] fail to submit a yarn-session task

Dsrong opened this issue over 1 year ago

[Bug] fail to submit a yarn-session task

Dsrong opened this issue over 1 year ago

[WIP] Add catalog management and sql gateway api

GOODBOY008 opened this pull request over 1 year ago

[Umbrella] Add testcontainer utils for integration test.

RocMarshal opened this issue over 1 year ago

[Bug] yarn application mode fail to submit job(s3p checkpoint)

ccpypy opened this issue over 1 year ago

[Bug] sql verify

charonjiang opened this issue over 1 year ago

Remove FlinkClientTrait duplicate code

ChengJie1053 opened this pull request over 1 year ago

[Feature] [Sql Gateway] Document and quickstart for users

GOODBOY008 opened this issue over 1 year ago

[Feature] [Sql Gateway] Catalog integrate with sql gateway

GOODBOY008 opened this issue over 1 year ago

[Feature] [Sql Gateway] Catalog management

GOODBOY008 opened this issue over 1 year ago

[Feature] [Sql Gateway] Workbench Front-end development

GOODBOY008 opened this issue over 1 year ago

[Feature] [Sql Gateway] Implement flink catalog use mysql as metadata store backend

GOODBOY008 opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Remove the old streampark-flink-kubernetes module code

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Modify docker and helm: Adding SVC configuration related to embedded file server.

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Refactor the state tracking of Flink on Kubernetes

Al-assad opened this issue over 1 year ago

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

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Refactor the lifecycle control of Flink session-mode jobs on Kubernetes

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Refactor the lifecycle control of Flink application-mode jobs on Kubernetes

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Port the new module codes to Streampark-flink-kubernetes-v2

Al-assad opened this issue over 1 year ago

[Feature] [Flink-K8s-V2] Create shaded module for flink-kubernetes-operator-api dependency

Al-assad opened this issue over 1 year ago

[Umbrella][Feature] Flink Kubernetes Module V2

Al-assad opened this issue over 1 year ago

Querying an unbounded table 'default_catalog.default_database.s3' in batch mode is not allowed. The table source is unbounded.[Bug] Bug title

heine0310 opened this issue over 1 year ago

Ecosyste.ms: OpenCollective

github.com/apache/incubator-streampark